Hello, Our team is using Kafka for the first time and are in the testing phase of getting a new product ready, which uses Kafka as the communications backbone. Basically, a processing unit will consume a message from a topic, do the processing, then produce the output to another topic. Messages get passed back and forth between processors until done.
We had an issue last week where an outdated processor was "stealing" messages from a topic, doing incorrect (outdated) processing, and putting it in the next topic. We could not find the rogue processor (aka consumer). We shut down all known consumers of that topic, and it was still happening. We finally gave up and renamed the topic to get around the issue. Is there a Kafka tool we could have used to find the connected consumer in that consumer group? Maybe by name or by IP? Thanks, Jillian
