Hello folks, I'd like to start a voting thread on adding dynamic routing functionality in Streams sink node. Please find a KIP here:
https://cwiki.apache.org/confluence/display/KAFKA/KIP- 303%3A+Add+Dynamic+Routing+in+Streams+Sink And the PR itself ready for review as well under KAFKA-4936: https://github.com/apache/kafka/pull/5018 Thanks! -- Guozhang