I have an implementation of a
in java, and currently it is never exiting the
method. When I drill down into the source code in debug mode I've found that it is getting stuck in the while loop in
, as the coordinator is never found.
The future returned from
in the loop fails the first time with
, and then will fail every subsequent time with
org.apache.kafka.common.errors.GroupCoordinatorNotAvailableException: The group coordinator is not available.
. Does anyone know why this might happen?
If I use the console producer/consumer I am able to successfully send and receive messages, it is only when I use my implementation of the KafkaConsumer. Additionally, the consumer does work on two of my servers so I know it is not the implementation of the consumer.
Here are the properties my consumer is created with:
Properties props = new Properties();
The topic is definitely created before the consumer starts.
I deleted all of the brokers in my cluster and recreated them, and now I'm failing at a different point. In
while trying to rejoin, the future returned from
repeatedly fails with
org.apache.kafka.common.errors.NotCoordinatorForGroupException: This is not the correct coordinator for this group.
. Still not sure what is going on.
I deleted the brokers and recreated them with a different id and now the
method is returning and it's successfully consuming messages. I'd still like to know why it failed in the first place though so I can make sure it doesn't happen again.