Class WakeupException
java.lang.Object
java.lang.Throwable
java.lang.Exception
java.lang.RuntimeException
org.apache.kafka.common.KafkaException
org.apache.kafka.common.errors.WakeupException
- All Implemented Interfaces:
Serializable
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:
Constructor Summary
ConstructorsMethod Summary
Methods inherited from class java.lang.Throwable
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString
Constructor Details
WakeupException
public WakeupException()