Hi, I'm facing an issue with New Consumer. I'm getting
GroupCoordinatorNotAvailableException during "poll" method:
  12:32:50,942 ERROR ConsumerCoordinator:362 - Auto offset commit failed.
   org.apache.kafka.common.errors.GroupCoordinatorNotAvailableException:
The group coordinator is not available.

Here is the code:
<code>
Properties consumerProps = new Properties();
consumerProps.put("bootstrap.servers", "localhost:9092");
consumerProps.put("group.id", "test");
consumerProps.setProperty("key.deserializer",
ByteArrayDeserializer.class.getName());
consumerProps.setProperty("value.deserializer",
ByteArrayDeserializer.class.getName());

consumer = new KafkaConsumer<>(consumerProps);
consumer.subscribe(Collections.singletonList("test-topic"));
Iterator<ConsumerRecord<byte[], byte[]>> recordIter =
consumer.poll(10000).iterator();
</code>

I've build kafka-clients.jar from master two days ago.
I'm using local server kafka_2.10-0.8.2.1. Is this ok or should I build new
server also?
Local server works well with client 0.8.2.2 and old consumer.

Thanks,
Alexey

Reply via email to