Class WakeupException

All Implemented Interfaces:
Serializable

public class WakeupException
extends KafkaException
Exception used to indicate preemption of a blocking operation by an external thread. For example, KafkaConsumer.wakeup() can be used to break out of an active KafkaConsumer.poll(java.time.Duration), which would raise an instance of this exception.
See Also:
Serialized Form
  • Constructor Details

    • WakeupException

      public WakeupException()