I'm working on a project that I hope to use the SimpleConsumer on. I'm trying
to write some test code around our code that is wrapping the SimpleConsumer.
The environment is 1 kafka broker, and 1 zookeeper
The test goes like this:
Create a topic ("foo", 1 partition, 1 replica)
Create a Producer, and send a message
Create a SimpleConsumer, and try to read the offset
Failure with: NotCoordinatorForConsumerException
If I continue to require for an extended period, I continue to get that
exception.
As near as I can tell, the topic metadata says there is a leader, but the the
broker thinks it's being rebalanced.
I've done the above test immediately after stop, clean out old data, and
restart both zookeeper and kafka.
Suggestions welcome.
