Kafka Broker and Streams Enhancements
Putting Events in Their Place with Dynamic Routing | Confluent

Putting Events in Their Place with Dynamic Routing | Confluent

4/4/2019 · Yeva Byzek

What this post added

Introduces KStream#branch() for static stream splitting based on predicates, creating new Kafka topics for different event subsets. Details dynamic routing using TopicNameExtractor (KIP-303) for runtime determination of output topic names, enabling routing based on event fields or enriched data from external sources like databases via JDBC Source Connector and GlobalKTable joins.

Read the original post ↗