What causes WakeupException?

Another thread called consumer.wakeup() to interrupt a blocking poll() — this is the standard, intentional way to break out of the poll loop for a clean shutdown Treated as an error when it is actually the expected control-flow signal for stopping a consumer

How do I fix WakeupException?

Catch WakeupException around poll(), then break the loop and call consumer.close() in a finally block — do not log it as an error during planned shutdown Only ignore it when shutdown was requested; if wakeup() was not called intentionally, investigate which thread triggered it Register a shutdown hook that calls consumer.wakeup() (not consumer.close()) from the signal thread, since close() is not safe from another thread

Is WakeupException retriable?

No — WakeupException is not retriable. Retrying the same call will not help; the underlying cause must be fixed first.

Kafka Exception `WakeupException`

org.apache.kafka.common.errors.WakeupException

Non-retriable Consumer

Exception used to indicate preemption of a blocking operation by an external thread. For example, wakeup can be used to break out of an active Duration), which would raise an instance of this exception.

Editorial scenario: verification date unknown. Verify against the installed version before changing data or configuration.

Common Causes

Another thread called consumer.wakeup() to interrupt a blocking poll() — this is the standard, intentional way to break out of the poll loop for a clean shutdown
Treated as an error when it is actually the expected control-flow signal for stopping a consumer

Solutions

Catch WakeupException around poll(), then break the loop and call consumer.close() in a finally block — do not log it as an error during planned shutdown
Only ignore it when shutdown was requested; if wakeup() was not called intentionally, investigate which thread triggered it
Register a shutdown hook that calls consumer.wakeup() (not consumer.close()) from the signal thread, since close() is not safe from another thread

Example Stack Trace

org.apache.kafka.common.errors.WakeupException
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.maybeTriggerWakeup(ConsumerNetworkClient.java:514)
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1230)

Hitting WakeupException in production? Conduktor Console gives you real-time visibility into clients, consumer groups, and broker health. Browse every Kafka exception or protocol error code.

Kafka Exception WakeupException

Common Causes

Solutions

Example Stack Trace

Related

Kafka Exception `WakeupException`