The new streams API added with KIP-28 is great. I’ve been using it on a prototype for a few weeks, and I’m looking forward to it being included in 0.9.0. However, at the moment, a Processor implementation is not able to specify the partition number when it outputs messages.
I’d be happy to log a JIRA and create a PR to add it to the API, but without knowing all of the history I’m wondering if leaving it out of the API was intentional. Thoughts? Best regards, Randall Hauch
