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 >
