Hi Randall, You can try to set the partitioner class as ProducerConfig.PARTITIONER_CLASS_CONFIG in the StreamsConfig, its interface can be found in
org.apache.kafka.clients.producer.Partitioner Let me know if it works for you. Guozhang On Tue, Oct 13, 2015 at 10:59 AM, Randall Hauch <rha...@gmail.com> wrote: > 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 > -- -- Guozhang
