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