Hey Jose, That error could indicate that one of the partitions of the __consumer_offsets topic has no leader. The group coordinators are chosen from the leaders of those partitions, so if one is unavailable, then the consumer won't be able to find the group. Can you show the output of the following command:
bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic __consumer_offsets (where the zookeeper hostname is replaced accordingly). -Jason On Tue, Apr 26, 2016 at 1:08 PM, José Raúl Pérez Rodríguez < joseraul.w...@gmail.com> wrote: > That is the problem, > > I can't see the stack trace, the KafkaConsumer don't throw any Exception, > it simply stay in *poll() *method and never return. I realized the > internal error was GroupCoordinatorNotAvailableException by using Kafka > from source code and tracing the method calls, I saw that *poll() *never > return because entered in a while loop whose condition depended on a > *Future*<> object that always fails, and the fail cause is > GroupCoordinatorNotAvailableException. > > Thans > > > > > On 4/26/2016 8:50 PM, Jason Gustafson wrote: > >> Hi Jose, >> >> Can you provide the full exception stack trace? Which method is this being >> throw from? It might help to see the snippet which is producing it as >> well. >> >> Thanks, >> Jason >> >> On Tue, Apr 26, 2016 at 5:19 AM, Jose Raul Perez Rodriguez < >> joseraul.w...@gmail.com> wrote: >> >> 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 >>> >>> >
