Package org.springframework.kafka

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 NestedRuntimeException

The Spring for Apache Kafka specific NestedRuntimeException implementation.

Author:

Gary Russell, Artem Bilan

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, Throwable cause)	Construct an instance with the provided properties.
KafkaException(String message, KafkaException.Level level, Throwable cause)	Construct an instance with the provided properties.

Method Summary

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

Methods inherited from class org.springframework.core.NestedRuntimeException

contains, getMostSpecificCause, getRootCause

Methods inherited from class java.lang.Throwable

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

Methods inherited from class java.lang.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,
 LogAccessor logger)

Log this exception at its log level.

Parameters:

message - the message.

logger - the log accessor.