KIP-303 — Add Dynamic Routing in Streams Sink

Accepted Kafka 2.0 Streams

Adds a TopicNameExtractor interface to the Kafka Streams DSL's to() sink operator, allowing the output topic name to be computed dynamically per-record from the record's key, value, and headers at runtime. All Streams topologies required output topic names to be known at topology build time, making it impossible to route records to dynamically chosen topics based on message content.

Details