Skip to content

Add Kafka/Redpanda streaming backend support#87

Merged
fuzziecoder merged 1 commit intocodex/fix-remaining-issues-and-raise-prfrom
codex/implement-real-time-streaming-pipelines
Feb 25, 2026
Merged

Add Kafka/Redpanda streaming backend support#87
fuzziecoder merged 1 commit intocodex/fix-remaining-issues-and-raise-prfrom
codex/implement-real-time-streaming-pipelines

Conversation

@fuzziecoder
Copy link
Copy Markdown
Owner

@fuzziecoder fuzziecoder commented Feb 25, 2026

Motivation

  • Introduce an explicit, configurable streaming backend so the event layer can target Kafka-compatible systems (Apache Kafka or Redpanda) and surface which backend emitted each event.

Description

  • Add EVENT_STREAM_BACKEND: Literal["kafka", "redpanda"] to Settings and keep existing bootstrap/topic settings in backend/config.py.
  • Update the event publisher (backend/events/publisher.py) to include stream_backend in emitted event envelopes and to make log messages reflect the selected backend when initialization or dependency issues occur.
  • Document the streaming choices and usage scenarios in backend/README.md and extend backend/.env.example with event-streaming keys and topic defaults.
  • Add unit tests backend/tests/test_event_publisher.py to verify backend tagging in published events and noop behavior when streaming is disabled.

Testing

  • Ran the focused test suite with PYTHONPATH=. pytest backend/tests/test_event_publisher.py backend/tests/test_event_streaming.py, and all tests passed (4 passed, 6 warnings).

Codex Task


Open with Devin

@vercel
Copy link
Copy Markdown

vercel bot commented Feb 25, 2026

The latest updates on your projects. Learn more about Vercel for GitHub.

Project Deployment Actions Updated (UTC)
flexi-roaster Ready Ready Preview, Comment Feb 25, 2026 1:20pm

@fuzziecoder fuzziecoder self-assigned this Feb 25, 2026
@fuzziecoder fuzziecoder merged commit 4a420ec into codex/fix-remaining-issues-and-raise-pr Feb 25, 2026
6 of 7 checks passed
@coderabbitai
Copy link
Copy Markdown

coderabbitai bot commented Feb 25, 2026

Important

Review skipped

Auto reviews are disabled on base/target branches other than the default branch.

Please check the settings in the CodeRabbit UI or the .coderabbit.yaml file in this repository. To trigger a single review, invoke the @coderabbitai review command.

You can disable this status message by setting the reviews.review_status to false in the CodeRabbit configuration file.

Use the checkbox below for a quick retry:

  • 🔍 Trigger review
✨ Finishing Touches
🧪 Generate unit tests (beta)
  • Create PR with unit tests
  • Post copyable unit tests in a comment
  • Commit unit tests in branch codex/implement-real-time-streaming-pipelines

Comment @coderabbitai help to get the list of available commands and usage tips.

Copy link
Copy Markdown

@devin-ai-integration devin-ai-integration bot left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

✅ Devin Review: No Issues Found

Devin Review analyzed this PR and found no potential bugs to report.

View in Devin Review to see 4 additional findings.

Open in Devin Review

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant