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 <mikfree...@gmail.com> 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 >
