Putting Events in Their Place with Dynamic Routing | Confluent
Apr 4, 2019Yeva Byzek

Summary
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.