public class WakeupException extends KafkaException
KafkaConsumer.wakeup() can be used to break out of an active KafkaConsumer.poll(java.time.Duration), which would raise an instance of this exception.| Constructor and Description |
|---|
WakeupException() |
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString