For future reference server the following is needed

offsets.topic.replication.factor=3

Michael

> On 14 Jul 2016, at 10:56, Michael Freeman <[email protected]> wrote:
> 
> Anyone have any ideas? Looks like the group coordinator is not failing over. 
> Or at least not detected by the Java consumer. 
> 
> A new leader is elected so I'm at a loss.
> 
> Michael
> 
>> On 13 Jul 2016, at 20:58, Michael Freeman <[email protected]> wrote:
>> 
>> Hi,
>>    I'm running a Kafka cluster with 3 nodes.
>> I have a topic with a replication factor of 3.
>> When I stop node 1 running kafka-topics.sh shows me that node 2 and 3 have 
>> successfully failed over the partitions for the topic.
>> 
>> The message producers are still sending messages and I can still consume 
>> them using kafka-console-consumer.sh
>> 
>> However my 0.9.0.1 Java consumer stops consuming messages. ( I thought maybe 
>> it was rebalancing but after an hour nothing) 
>> 
>> The consumer logs simply contains lots of "Marking the coordinator 
>> 8147683647 dead."
>> 
>> If I start node 1 up the consumers detect this and start to consume messages 
>> again.
>> 
>> On startup of the consumers I can see that all three nodes are listed in the 
>> "bootstrap.servers".
>> 
>> Any idea whats wrong with the Java consumer?
>> 
>> Thanks for any help or pointers in the right direction.
>> 
>> Michael
>> 

Reply via email to