Hello folks,

I'd like to start a discussion on adding dynamic routing functionality in
Streams sink node. I.e. users do not need to specify the topic name at
compilation time but can dynamically determine which topic to send to based
on each record's key value pairs. Please find a KIP here:

https://cwiki.apache.org/confluence/display/KAFKA/KIP-303%3A+Add+Dynamic+Routing+in+Streams+Sink

Any feedbacks are highly appreciated.

Thanks!

-- Guozhang

Reply via email to