unable to receive messages to all consumer groups if they subscribed to same topics

[himanshuatjudo]

Here are the scenario and steps,

• I have two topics part34.xxx (2 partitions) and part35.xxx (1 partition)
• subscribe group4 and group5 for above both topics
• produce messages on part34.xxx and part35.xxx
  I only receive the messages whichever group was subscribe first which doesn't seems to right behavior.

[ajperrins]

There is a bug in the re-balancing logic when you have multiple consumers groups consuming from the same topic. The bug is in ZkUtils.GetConsumersPerTopic, which doesn't filter the consumers by the group argument.

I haven't put in a pull request, because we made other changes, like upgrading Zookeeper, which the original author might not want to accept. But I can refer you to my commit where you can make a similar change on ZkUtils.cs, line 436, to filter by the group ID.

Hope this helps.

[initialBoy]

Here are the scenario,

Consumers with the same partition can not receive messages at the same time.

[initialBoy]

I don't know how to filter the consumers by the group argument.Because I don't know where to start

[raskolnikoov]

This is fixed in this #6