Hey, I'm facing a critical issue. I'm using flink 1.17.1. Flink Job has multiple sources After adding logs and custom consumers everywhere, I figured out, that records go to both consumer A and consumer B. Actually, I have more than 3 consumers, but here is an example: Consumer A (topic A) Consumer B (topic B) Consumer C (topic C) I found logs, that consumer B also tries to read topic A and consumer C tries to read B Here are my custom logs:

Wrong topic for consumer C B
Wrong topic for consumer B A

Interesting thing is that consumer A and consumer B also receives same data, as it should, so it's not simple re-routing. Each consumer have separate kafka group. Let me know which details I can provide? Thanks in advance