org.apache.kafka.common.errors.WakeupException

GitHub | nemccarthy | 3 months ago
  1. 0

    GitHub comment 224#246287041

    GitHub | 3 months ago | nemccarthy
    org.apache.kafka.common.errors.WakeupException

    Root Cause Analysis

    1. org.apache.kafka.common.errors.WakeupException

      No message provided

      at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.maybeTriggerWakeup()
    2. org.apache.kafka
      ConsumerCoordinator.ensurePartitionAssignment
      1. org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.maybeTriggerWakeup(ConsumerNetworkClient.java:367)
      2. org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:361)
      3. org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:224)
      4. org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:192)
      5. org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:163)
      6. org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:243)
      7. org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.ensurePartitionAssignment(ConsumerCoordinator.java:366)
      7 frames
    3. Apache Kafka
      KafkaConsumer.poll
      1. org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:978)
      2. org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:938)
      2 frames
    4. akka.kafka
      KafkaConsumerActor$$anonfun$receive$1.applyOrElse
      1. akka.kafka.KafkaConsumerActor.poll(KafkaConsumerActor.scala:193)
      2. akka.kafka.KafkaConsumerActor$$anonfun$receive$1.applyOrElse(KafkaConsumerActor.scala:113)
      2 frames
    5. Akka Actor
      Actor$class.aroundReceive
      1. akka.actor.Actor$class.aroundReceive(Actor.scala:484)
      1 frame
    6. akka.kafka
      KafkaConsumerActor.aroundReceive
      1. akka.kafka.KafkaConsumerActor.aroundReceive(KafkaConsumerActor.scala:66)
      1 frame
    7. Akka Actor
      Mailbox.run
      1. akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
      2. akka.actor.ActorCell.invoke(ActorCell.scala:495)
      3. akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
      4. akka.dispatch.Mailbox.run(Mailbox.scala:224)
      4 frames
    8. Java RT
      Thread.run
      1. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
      2. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
      3. java.lang.Thread.run(Thread.java:745)
      3 frames