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:

java.io.Serializable

Direct Known Subclasses:

BatchListenerFailedException, ConversionException, DeserializationException, KafkaProducerException, KafkaReplyTimeoutException, ListenerExecutionFailedException

public class KafkaException
extends org.springframework.core.NestedRuntimeException

The Spring Kafka specific NestedRuntimeException implementation.

Author:

Gary Russell, Artem Bilan

See Also:

Serialized Form

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class org.springframework.core.NestedRuntimeException

contains, getMessage, getMostSpecificCause, getRootCause

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, 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 Detail

KafkaException

public KafkaException(java.lang.String message)

Construct an instance with the provided properties.

Parameters:

message - the message.

KafkaException

public KafkaException(java.lang.String message,
                      @Nullable
                      java.lang.Throwable cause)

Construct an instance with the provided properties.

Parameters:

message - the message.

cause - the cause.

KafkaException

public KafkaException(java.lang.String message,
                      KafkaException.Level level,
                      @Nullable
                      java.lang.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 Detail

selfLog

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

Log this exception at its log level.

Parameters:

message - the message.

logger - the log accessor.