Kafka Streams - exposing processor name in DSL

Hi! I was trying to build a topology using the DSL, add a custom processor and then add a sink for it. However, it seems like there's no great way to do this using the APIs, since the processor's internal "name" is not exposed in the KStream interface, and the .process method doesn't return the l

Re: Kafka Streams - exposing processor name in DSL

uozhang > > > > On Wed, Mar 23, 2016 at 10:17 AM, Jon Bender > wrote: > > > Hi! > > > > I was trying to build a topology using the DSL, add a custom processor > and > > then add a sink for it. However, it seems like there's no great way to >

Leader for almost all topic, partitions on the same broker

Hello, I have a 3-node cluster that has had a couple issues lately. One thing I'm trying to sort out is why the topic-partitions are all owned by a single leader (when i list topics, the leader is assigned to the current controller node, irrespective the preferred replica). I have tried to use t

Re: Leader for almost all topic, partitions on the same broker

did not successfully startup and hence cannot take any > partitions. > > Guozhang > > > On Wed, May 14, 2014 at 11:45 AM, Jon Bender >wrote: > > > Hello, > > > > I have a 3-node cluster that has had a couple issues lately. One thing > I'm >