Class KafkaException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

org.springframework.core.NestedRuntimeException

org.springframework.kafka.KafkaException

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

BatchListenerFailedException, ConversionException, DeserializationException, KafkaBackoffException, KafkaProducerException, KafkaReplyTimeoutException, ListenerExecutionFailedException, NoProducerAvailableException, TimestampedException

public class KafkaException
extends org.springframework.core.NestedRuntimeException

The Spring for Apache Kafka specific NestedRuntimeException implementation.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	KafkaException.Level	The log level for KafkaException.

Constructor Summary

Constructors

Constructor	Description
KafkaException(String message)	Construct an instance with the provided properties.
KafkaException(String message, @Nullable Throwable cause)	Construct an instance with the provided properties.
KafkaException(String message, KafkaException.Level level, @Nullable Throwable cause)	Construct an instance with the provided properties.

Method Summary

Modifier and Type	Method	Description
void	selfLog(String message, org.springframework.core.log.LogAccessor logger)	Log this exception at its log level.

Methods inherited from class org.springframework.core.NestedRuntimeException

contains, getMostSpecificCause, getRootCause

Methods inherited from class Throwable

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

Methods inherited from class Object

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

Constructor Details

KafkaException

public KafkaException(String message)

Construct an instance with the provided properties.

Parameters:

message - the message.

KafkaException

public KafkaException(String message,
 @Nullable Throwable cause)

Construct an instance with the provided properties.

Parameters:

message - the message.

cause - the cause.

KafkaException

public KafkaException(String message,
 KafkaException.Level level,
 @Nullable Throwable cause)

Construct an instance with the provided properties.

Parameters:

message - the message.

level - the level at which this exception should be logged when using selfLog(String, LogAccessor).

cause - the cause.

Method Details

selfLog

public void selfLog(String message,
 org.springframework.core.log.LogAccessor logger)

Log this exception at its log level.

Parameters:

message - the message.

logger - the log accessor.