Hi Henry, Could you share the code that builds your topology so we see how the topics are passed in? Also, this would depend on what the streaming logic is doing with the topics, e.g., if you're joining them then both partitions need to be consumed by the same instance.
Eno > On 28 Apr 2017, at 11:01, Henry Thacker <he...@henrythacker.com> wrote: > > Hi, > > I'm using Kafka 0.10.0.1 and Kafka streams. When I have two different > processes, Consumer 1 and 2. They both share the same application ID, but > subscribe for different single-partition topics. Only one stream consumer > receives messages. > > The non working stream consumer just sits there logging: > > Starting stream thread [StreamThread-1] > Discovered coordinator <Host> (Id: ...) for group my-streamer > Revoking previously assigned partitions [] for group my-streamer > (Re-)joining group my-streamer > Successfully joined group my-streamer with generation 3 > Setting newly assigned partitions [] for group my-streamer > (Re-)joining group my-streamer > Successfully joined group my-streamer with generation 4 > > If I was trying to subscribe to the same topic & partition I could > understand this behaviour, but given that the subscriptions are for > different input topics, I would have thought this should work? > > Thanks, > Henry > > -- > Henry Thacker
