Skip to content

Conversation

@psteinroe
Copy link
Owner

@psteinroe psteinroe commented Jan 7, 2026

Summary

  • Add KafkaSink that publishes events to Kafka topics
  • Sends event.payload as JSON message value
  • Supports dynamic topic and partition key via event metadata

Configuration

sink:
  type: kafka
  brokers: localhost:9092
  topic: events        # optional default topic

Routing

Topic and key are resolved from:

  1. topic and partition_key fields in event metadata
  2. Fallback to config values

@psteinroe psteinroe force-pushed the feat/sink-anysink-infrastructure branch from 80a1ebf to 9b72e54 Compare January 8, 2026 11:26
@psteinroe psteinroe changed the base branch from feat/sink-anysink-infrastructure to main January 8, 2026 13:20
@psteinroe psteinroe merged commit 6e36405 into main Jan 13, 2026
6 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.

2 participants