Hello,
I am using KafkaProducer and KafkaConsumer, version 0.90, in java, the
producer works good (the Console Consumer provided in samples receives
the producer data).
But in the configured KafkaConsumer I got the
/org.apache.kafka.common.errors.GroupCoordinatorNotAvailableException/**error
The error is thrown in /handleGroupMetadataResponse(ClientResponse resp,
RequestFuture<Void> future)/**method**of class
/org.apache.kafka.clients.consumer.internals.AbstractCoordinator/
The consumer configuration:
/props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,"0.1.2.3:9092");//
//props.put(ConsumerConfig.GROUP_ID_CONFIG, "my_group");//
//props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "true");//
//props.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, "60000");//
//props.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, "20000");//
//props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,
"org.apache.kafka.common.serialization.IntegerDeserializer");//
//props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,
"org.apache.kafka.common.serialization.StringDeserializer");//
/The broker configuration has no significant changes.
I detect the error using Kafka from source code and tracing the methods
manually, because no raise any exception when used from compiled .jars.
What can i do in order to, at least, known more details about this
error, or ideally solving it ;-)
Thanks
//
