Skip to content

feat(pipeline): add fail-closed Kafka event sink - #2616

Merged
twoimo merged 3 commits into
mainfrom
data
Aug 18, 2026
Merged

twoimo merged 3 commits into
mainfrom
data

Conversation

@twoimo

@twoimo twoimo commented Aug 18, 2026

Copy link
Copy Markdown
Owner

Summary

Promote Kafka Slice 1 event sink from data to main after #2615.

Local re-run counts

  • unittest 52 tests OK

twoimo and others added 3 commits August 18, 2026 16:37
Opt-in TZUDONG_PIPELINE_EVENTS=kafka publishes allowlisted envelopes.
Default stays noop. Missing client/bootstrap/host/mode fail closed.
Move kafka+kafka-ui to a container-only fragment with no host 9092.
feat(pipeline): add fail-closed Kafka event sink
feat(pipeline): add fail-closed Kafka event sink
@chatgpt-codex-connector

Copy link
Copy Markdown

You have reached your Codex usage limits for code reviews. You can see your limits in the Codex usage dashboard.

@twoimo
twoimo merged commit ff72cd5 into main Aug 18, 2026
11 of 12 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant