Package org.apache.kafka.common.errors

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

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 Summary

Constructors

Constructor	Description
WakeupException()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Constructor Detail

WakeupException

public WakeupException()