Probably we should return an error response if you already have a partition assignment strategy inplace for a group and you try to use other strategy.
Thanks, Mayuresh On Tue, Mar 17, 2015 at 2:10 PM, Jiangjie Qin <j...@linkedin.com.invalid> wrote: > Yeah, using different partition assignment algorithms in the same consumer > group won¹t work. Is there a particular reason you want to do this? > > On 3/17/15, 8:32 AM, "tao xiao" <xiaotao...@gmail.com> wrote: > > >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 > > -- -Regards, Mayuresh R. Gharat (862) 250-7125
