Re: Group coordinator in 0.9

2016-01-10 Thread Stevo Slavić
Hello Oleksiy, All offsets for given consumer group are stored in (and fetched from) one and only one partition of all partitions of __consumer_offsets topic. By default __consumer_offsets has 50 partitions and for each of these partitions replication factor is 3, so there is one lead and 2 extra

Group coordinator in 0.9

2016-01-09 Thread Oleksiy Krivoshey
Hi! Is it possible for the group coordinator for the same group to change from one host to some other during cluster runtime? For example when the host that used to be the coordinator is down - can Kafka cluster choose new coordinator for the group? Or is it fixed? Thanks!