This is the corrected zk result Here is the result from zk [zk: localhost:2181(CONNECTED) 0] get /consumers/test/owners/mm-benchmark-test/0
Node does not exist: /consumers/test/owners/mm-benchmark-test/0 [zk: localhost:2181(CONNECTED) 1] get /consumers/test/owners/mm-benchmark-test1/0 test-localhost-1426605370072-904d6fba-0 On Tue, Mar 17, 2015 at 11:30 PM, tao xiao <xiaotao...@gmail.com> wrote: > Hi team, > > I have two consumer instances with the same group id connecting to two > different topics with 1 partition created for each. One consumer uses > partition.assignment.strategy=roundrobin and the other one uses default > assignment strategy. Both consumers have 1 thread spawned internally and > connect kafka using createMessageStreamsByFilter. > The consumer with roundrobin assignment strategy connected kafka first and > had 2 topics assigned to itself and then I brought up another consumer that > has default assignment strategy configured. I saw rebalancing happened in > both consumers but at the end only one of the topics was assigned to the > consumer that is configured roundrobin assignment strategy and no topics > were assigned to the other consumer. This led to one topic missing its > owner. > > Here is the result from zk > [zk: localhost:2181(CONNECTED) 0] get > /consumers/test/owners/mm-benchmark-test/0 > > Node does not exist: > /consumers/test12345667fffff/owners/mm-benchmark-test/0 > > [zk: localhost:2181(CONNECTED) 1] get > /consumers/test/owners/mm-benchmark-test1/0 > > test-localhost-1426605370072-904d6fba-0 > > The kafka version I use is 0.8.2.1 > > -- > Regards, > Tao > -- Regards, Tao
