kafka-avro-console-consumer throws KafkaException: Unexpected error from SyncGroupWhat determines Kafka consumer offset?java.lang.IllegalArgumentException kafka console consumerSpring kafka does not support Large message consumersKafka Stream - CommitFailedException: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another memberCommitFailedException: Commit cannot be completed since the group has already rebalancedKafka consumer and producer throwing errorKafka Connect Avro Console Consumer HangingLoggingMessageFormatter with kafka-avro-console-consumerUnknown magic byte with kafka-avro-console-consumerKafka avro console consumer is not displaying any messages from kafka connect

A reference to a well-known characterization of scattered compact spaces

Did Shadowfax go to Valinor?

What is a clear way to write a bar that has an extra beat?

What is the intuition behind short exact sequences of groups; in particular, what is the intuition behind group extensions?

What about the virus in 12 Monkeys?

Today is the Center

Arrow those variables!

Why was the shrinking from 8″ made only to 5.25″ and not smaller (4″ or less)?

How is it possible to have an ability score that is less than 3?

Is it inappropriate for a student to attend their mentor's dissertation defense?

What reasons are there for a Capitalist to oppose a 100% inheritance tax?

Has there ever been an airliner design involving reducing generator load by installing solar panels?

Can one be a co-translator of a book, if he does not know the language that the book is translated into?

Were any external disk drives stacked vertically?

Emailing HOD to enhance faculty application

Assassin's bullet with mercury

Intersection of two sorted vectors in C++

What to put in ESTA if staying in US for a few days before going on to Canada

Is it unprofessional to ask if a job posting on GlassDoor is real?

Combinations of multiple lists

Theorems that impeded progress

Western buddy movie with a supernatural twist where a woman turns into an eagle at the end

Blender 2.8 I can't see vertices, edges or faces in edit mode

I Accidentally Deleted a Stock Terminal Theme



kafka-avro-console-consumer throws KafkaException: Unexpected error from SyncGroup


What determines Kafka consumer offset?java.lang.IllegalArgumentException kafka console consumerSpring kafka does not support Large message consumersKafka Stream - CommitFailedException: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another memberCommitFailedException: Commit cannot be completed since the group has already rebalancedKafka consumer and producer throwing errorKafka Connect Avro Console Consumer HangingLoggingMessageFormatter with kafka-avro-console-consumerUnknown magic byte with kafka-avro-console-consumerKafka avro console consumer is not displaying any messages from kafka connect






.everyoneloves__top-leaderboard:empty,.everyoneloves__mid-leaderboard:empty,.everyoneloves__bot-mid-leaderboard:empty height:90px;width:728px;box-sizing:border-box;








0















I'm doing a simple console consumer query on a test topic that should have a couple of records. FYI, I recently deleted the topic and then called a REST service to produce a record there, which recreated the topic.



This is with Confluent Platform 5.0.1 which runs Apache Kafka 2.0.1.



Googling this error, I can see https://issues.apache.org/jira/browse/KAFKA-6631, which has the same error, but I'm not using Streams at all. My current usage is very simple.



sudo /usr/bin/kafka-avro-console-consumer --bootstrap-server localhost:9092 --topic metric-api-events-test --from-beginning

[2019-03-08 23:28:46,642] ERROR Unknown error when running consumer: (kafka.tools.ConsoleConsumer$:76)
org.apache.kafka.common.KafkaException: Unexpected error from SyncGroup: The server experienced an unexpected error when processing the request
 at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:638)
 at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:611)
 at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:894)
 at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:874)
 at org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:204)
 at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:167)
 at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:127)
 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:586)
 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:400)
 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:303)
 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:242)
 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:218)
 at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:413)
 at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:352)
 at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:337)
 at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:343)
 at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1218)
 at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1181)
 at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1115)
 at kafka.tools.ConsoleConsumer$ConsumerWrapper.<init>(ConsoleConsumer.scala:387)
 at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:71)
 at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:53)
 at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
[2019-03-08 23:28:46,642] ERROR Unknown error when running consumer: (kafka.tools.ConsoleConsumer$:76)
org.apache.kafka.common.KafkaException: Unexpected error from SyncGroup: The server experienced an unexpected error when processing the request
 at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:638)
 at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:611)
 at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:894)
 at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:874)
 at org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:204)
 at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:167)
 at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:127)
 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:586)
 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:400)
 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:303)
 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:242)
 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:218)
 at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:413)
 at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:352)
 at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:337)
 at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:343)
 at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1218)
 at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1181)
 at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1115)
 at kafka.tools.ConsoleConsumer$ConsumerWrapper.<init>(ConsoleConsumer.scala:387)
 at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:71)
 at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:53)
 at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)





apache-kafka







share|improve this question






























    0















    I'm doing a simple console consumer query on a test topic that should have a couple of records. FYI, I recently deleted the topic and then called a REST service to produce a record there, which recreated the topic.



    This is with Confluent Platform 5.0.1 which runs Apache Kafka 2.0.1.



    Googling this error, I can see https://issues.apache.org/jira/browse/KAFKA-6631, which has the same error, but I'm not using Streams at all. My current usage is very simple.



    sudo /usr/bin/kafka-avro-console-consumer --bootstrap-server localhost:9092 --topic metric-api-events-test --from-beginning

    [2019-03-08 23:28:46,642] ERROR Unknown error when running consumer: (kafka.tools.ConsoleConsumer$:76)
    org.apache.kafka.common.KafkaException: Unexpected error from SyncGroup: The server experienced an unexpected error when processing the request
     at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:638)
     at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:611)
     at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:894)
     at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:874)
     at org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:204)
     at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:167)
     at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:127)
     at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:586)
     at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:400)
     at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:303)
     at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:242)
     at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:218)
     at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:413)
     at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:352)
     at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:337)
     at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:343)
     at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1218)
     at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1181)
     at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1115)
     at kafka.tools.ConsoleConsumer$ConsumerWrapper.<init>(ConsoleConsumer.scala:387)
     at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:71)
     at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:53)
     at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
    [2019-03-08 23:28:46,642] ERROR Unknown error when running consumer: (kafka.tools.ConsoleConsumer$:76)
    org.apache.kafka.common.KafkaException: Unexpected error from SyncGroup: The server experienced an unexpected error when processing the request
     at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:638)
     at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:611)
     at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:894)
     at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:874)
     at org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:204)
     at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:167)
     at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:127)
     at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:586)
     at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:400)
     at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:303)
     at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:242)
     at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:218)
     at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:413)
     at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:352)
     at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:337)
     at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:343)
     at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1218)
     at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1181)
     at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1115)
     at kafka.tools.ConsoleConsumer$ConsumerWrapper.<init>(ConsoleConsumer.scala:387)
     at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:71)
     at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:53)
     at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)





    apache-kafka







    share|improve this question


























      0












      0








      0








      I'm doing a simple console consumer query on a test topic that should have a couple of records. FYI, I recently deleted the topic and then called a REST service to produce a record there, which recreated the topic.



      This is with Confluent Platform 5.0.1 which runs Apache Kafka 2.0.1.



      Googling this error, I can see https://issues.apache.org/jira/browse/KAFKA-6631, which has the same error, but I'm not using Streams at all. My current usage is very simple.



      sudo /usr/bin/kafka-avro-console-consumer --bootstrap-server localhost:9092 --topic metric-api-events-test --from-beginning

      [2019-03-08 23:28:46,642] ERROR Unknown error when running consumer: (kafka.tools.ConsoleConsumer$:76)
      org.apache.kafka.common.KafkaException: Unexpected error from SyncGroup: The server experienced an unexpected error when processing the request
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:638)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:611)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:894)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:874)
       at org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:204)
       at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:167)
       at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:127)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:586)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:400)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:303)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:242)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:218)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:413)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:352)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:337)
       at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:343)
       at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1218)
       at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1181)
       at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1115)
       at kafka.tools.ConsoleConsumer$ConsumerWrapper.<init>(ConsoleConsumer.scala:387)
       at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:71)
       at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:53)
       at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
      [2019-03-08 23:28:46,642] ERROR Unknown error when running consumer: (kafka.tools.ConsoleConsumer$:76)
      org.apache.kafka.common.KafkaException: Unexpected error from SyncGroup: The server experienced an unexpected error when processing the request
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:638)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:611)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:894)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:874)
       at org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:204)
       at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:167)
       at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:127)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:586)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:400)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:303)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:242)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:218)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:413)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:352)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:337)
       at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:343)
       at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1218)
       at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1181)
       at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1115)
       at kafka.tools.ConsoleConsumer$ConsumerWrapper.<init>(ConsoleConsumer.scala:387)
       at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:71)
       at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:53)
       at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)





      apache-kafka







      share|improve this question
















      I'm doing a simple console consumer query on a test topic that should have a couple of records. FYI, I recently deleted the topic and then called a REST service to produce a record there, which recreated the topic.



      This is with Confluent Platform 5.0.1 which runs Apache Kafka 2.0.1.



      Googling this error, I can see https://issues.apache.org/jira/browse/KAFKA-6631, which has the same error, but I'm not using Streams at all. My current usage is very simple.



      sudo /usr/bin/kafka-avro-console-consumer --bootstrap-server localhost:9092 --topic metric-api-events-test --from-beginning

      [2019-03-08 23:28:46,642] ERROR Unknown error when running consumer: (kafka.tools.ConsoleConsumer$:76)
      org.apache.kafka.common.KafkaException: Unexpected error from SyncGroup: The server experienced an unexpected error when processing the request
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:638)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:611)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:894)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:874)
       at org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:204)
       at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:167)
       at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:127)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:586)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:400)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:303)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:242)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:218)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:413)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:352)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:337)
       at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:343)
       at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1218)
       at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1181)
       at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1115)
       at kafka.tools.ConsoleConsumer$ConsumerWrapper.<init>(ConsoleConsumer.scala:387)
       at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:71)
       at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:53)
       at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
      [2019-03-08 23:28:46,642] ERROR Unknown error when running consumer: (kafka.tools.ConsoleConsumer$:76)
      org.apache.kafka.common.KafkaException: Unexpected error from SyncGroup: The server experienced an unexpected error when processing the request
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:638)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:611)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:894)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:874)
       at org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:204)
       at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:167)
       at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:127)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:586)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:400)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:303)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:242)
       at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:218)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:413)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:352)
       at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:337)
       at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:343)
       at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1218)
       at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1181)
       at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1115)
       at kafka.tools.ConsoleConsumer$ConsumerWrapper.<init>(ConsoleConsumer.scala:387)
       at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:71)
       at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:53)
       at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)





      apache-kafka




      apache-kafka






      share|improve this question















      share|improve this question













      share|improve this question




      share|improve this question








      edited Mar 9 at 11:53









      Giorgos Myrianthous

      5,26521746




      5,26521746










      asked Mar 8 at 23:34









      clayclay

      5,04854292




      5,04854292






















          0






          active

          oldest

          votes












          Your Answer






          StackExchange.ifUsing("editor", function ()
          StackExchange.using("externalEditor", function ()
          StackExchange.using("snippets", function ()
          StackExchange.snippets.init();
          );
          );
          , "code-snippets");

          StackExchange.ready(function()
          var channelOptions =
          tags: "".split(" "),
          id: "1"
          ;
          initTagRenderer("".split(" "), "".split(" "), channelOptions);

          StackExchange.using("externalEditor", function()
          // Have to fire editor after snippets, if snippets enabled
          if (StackExchange.settings.snippets.snippetsEnabled)
          StackExchange.using("snippets", function()
          createEditor();
          );

          else
          createEditor();

          );

          function createEditor()
          StackExchange.prepareEditor(
          heartbeatType: 'answer',
          autoActivateHeartbeat: false,
          convertImagesToLinks: true,
          noModals: true,
          showLowRepImageUploadWarning: true,
          reputationToPostImages: 10,
          bindNavPrevention: true,
          postfix: "",
          imageUploader:
          brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
          contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
          allowUrls: true
          ,
          onDemand: true,
          discardSelector: ".discard-answer"
          ,immediatelyShowMarkdownHelp:true
          );



          );













          draft saved

          draft discarded


















          StackExchange.ready(
          function ()
          StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f55072443%2fkafka-avro-console-consumer-throws-kafkaexception-unexpected-error-from-syncgro%23new-answer', 'question_page');

          );

          Post as a guest















          Required, but never shown

























          0






          active

          oldest

          votes








          0






          active

          oldest

          votes









          active

          oldest

          votes






          active

          oldest

          votes















          draft saved

          draft discarded
















































          Thanks for contributing an answer to Stack Overflow!


          • Please be sure to answer the question. Provide details and share your research!

          But avoid …


          • Asking for help, clarification, or responding to other answers.

          • Making statements based on opinion; back them up with references or personal experience.

          To learn more, see our tips on writing great answers.




          draft saved


          draft discarded














          StackExchange.ready(
          function ()
          StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f55072443%2fkafka-avro-console-consumer-throws-kafkaexception-unexpected-error-from-syncgro%23new-answer', 'question_page');

          );

          Post as a guest















          Required, but never shown





















































          Required, but never shown














          Required, but never shown












          Required, but never shown







          Required, but never shown

































          Required, but never shown














          Required, but never shown












          Required, but never shown







          Required, but never shown







          -

          Popular posts from this blog

          Thal And Out Agency railway station See also References External links Navigation menuOfficial Web Site of Pakistan RailwaysArchivedOfficial Web Site of Pakistan Railwayseeexpanding ite

          Image
          Golra Sharif KutbalFatehjangGaganChauntraKahal Basal Junction DomelNammalChura Sharif HaltLangar Jand Junction Khushalgarh Faqir Hussain ShaheedTilkanSeni GambatBabari BandaCadet College Kohat Kohat Cantonment Kohat Tehsil Nasrat Khel Chikarkot Ustarzai Raisan Ibrahimzai Hangu Doaba Darsmand Thal Aab-e-gumAhmedwalAlam RegAlozaiAzadBadinzaiBakhtiarabad DomkiBeleli Bostan Junction Chaman ChurmianDalbandinDamboliDera Allah YarDera Murad JamaliDingraDozanGalangurGatGulistanHirokKan MehtarzaiKhanaiKhan Muhammad ChahKila SaifullahKishingiKoh-e-TaftanKolpurKuchlakMachMangoliMirjavehMushkafMuslimbaghNok KundiNushkiNuttallPadag RoadPerakPehro KunriPanirPeshiQilla Abdullah Quetta Sar-i-AbSheikh MandahSheikh Wasil Sibi Junction Spezand Junction Shela BaghTozghiWali KhanYakmachYaru Zhob IslamabadGolra Sharif Junction Attock City Junction Attock KhurdBahawalpurChiniotDandot RSFaisalabadGujar KhanGujratJalloJhang SadarJhelum Khanewal Junction KhanpurKhewra Lahore Junction Lahore CantonmentLiaquat Pu...
          Read more

          Posting a File and Associated Data to a RESTful WebService preferably as JSON2019 Community Moderator ElectionREST URI convention - Singular or plural name of resource while creating itUploading both data and files in one form using Ajax?How do I upload a file with metadata using a REST web service?REST API - file (ie images) processing - best practicesSpring: JSON data and file in the same requestREST API Put large dataPosting a file and JSON data to Spring rest serviceRESTful Web Service Upload/Download Large Data With JSONREST API Design sending JSON data and a file to the api in same requestPost JSONArray to REST servicePUT vs. POST in RESTParsing values from a JSON file?JavaScript/jQuery to download file via POST with JSON dataHow do I upload a file with metadata using a REST web service?How to POST JSON data with Curl from Terminal/Commandline to Test Spring REST?Separate REST JSON API server and client?what's the correct way to send a file from REST web service to client?How do I write JSON data to a file?What is “406-Not Acceptable Response” in HTTP?REST API - file (ie images) processing - best practices

          Image
          Convert an array of objects to array of the objects' values Can a space-faring robot still function over a billion years? ESPP--any reason not to go all in? Create chunks from an array Has a sovereign Communist government ever run, and conceded loss, on a fair election? When to use the term transposed instead of modulation? How to chmod files that have a specific set of permissions Is this nominative case or accusative case? Are there other characters in the Star Wars universe who had damaged bodies and needed to wear an outfit like Darth Vader? What does "rhumatis" mean? How to write a chaotic neutral protagonist and prevent my readers from thinking they are evil? Can a Mimic (container form) actually hold loot? A bug in Excel? Conditional formatting for marking duplicates also highlights unique value What is Tony Stark injecting into himself in Iron Man 3? Iron deposits mined from under the city Why would the IRS ask for birth certificates ...
          Read more

          How can I change the color of pagination dots of UIPageControl?How to change UIPageControl dotsIs there a way to change page indicator dots colorCustomize dot with image of UIPageControl at index 0 of UIPageControlNo visible @interface for 'NSObject<PageControlDelegate>' declares the selector 'pageControlPageDidChange:'How to change the color of pagination dots in UIPageControl with a different color per pagepagecontrol indicator custom image instead of DefaultChanging the colour of UIPageControl dots in MonoTouchpagecontrol selectable page visibility color?Alternative way to load ViewControllers on a UIPageControlHow to set only layer.border-color for UIpage control dots in swiftHow can I develop for iPhone using a Windows development machine?How to change the name of an iOS app?UITableView - change section header coloruipagecontrol indicator(dot)issueCustom UIPageControl dots color not changingchange the interspace between UIPageControl dotsHow to change Status Bar text color in iOSHow can I change image tintColor in iOS and WatchKitUIPageControl dots with larger space in between each dotsHow to change the color of pagination dots in UIPageControl with a different color per page

          Image
          How do I implement a file system driver driver in Linux? Fly on a jet pack vs fly with a jet pack? Is possible to search in vim history? Translation of Scottish 16th century church stained glass Ridge Regression with Gradient Descent Converges to OLS estimates What linear sensor for a keyboard? Did US corporations pay demonstrators in the German demonstrations against article 13? Is it improper etiquette to ask your opponent what his/her rating is before the game? Why does Async/Await work properly when the loop is inside the async function and not the other way around? Why did the EU agree to delay the Brexit deadline? A Permanent Norse Presence in America Did arcade monitors have same pixel aspect ratio as TV sets? Can the Supreme Court overturn an impeachment? Drawing ramified coverings with tikz Greco-Roman egalitarianism Can someone explain how this makes sense electrically? Is it possible to use .desktop files to open local pdf files on specific pa...
          Read more