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
