kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tao xiao <xiaotao...@gmail.com>
Subject Re: New Consumer throws GroupCoordinatorNotAvailableException
Date Mon, 02 Nov 2015 05:01:32 GMT
The new consumer only works with the broker in trunk now which will soon
become 0.9

On Sun, 1 Nov 2015 at 20:54 Alexey Pirogov <pirogov.alexey@gmail.com> wrote:

> 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
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message