Class ConversionException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

org.springframework.core.NestedRuntimeException

org.springframework.kafka.KafkaException

org.springframework.kafka.support.converter.ConversionException

All Implemented Interfaces:

Serializable

public class ConversionException
extends KafkaException

Exception for conversions.

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class KafkaException

KafkaException.Level

Constructor Summary

Constructors

Constructor	Description
ConversionException(String message, @Nullable Throwable cause)	Construct an instance with the provided properties.
ConversionException(String message, List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, Throwable cause)	Construct an instance with the provided properties.
ConversionException(String message, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, Throwable cause)	Construct an instance with the provided properties.
ConversionException(String message, org.springframework.messaging.Message<?> msg, Throwable cause)	Construct an instance with the provided properties.

Method Summary

Modifier and Type	Method	Description
@Nullable org.springframework.messaging.Message<?>	getMsg()	Return the Message, if available.
@Nullable org.apache.kafka.clients.consumer.ConsumerRecord<?,?>	getRecord()	Return the consumer record, if available.
List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>	getRecords()	Return the consumer record, if available.

Methods inherited from class KafkaException

selfLog

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

ConversionException

public ConversionException(String message,
 @Nullable Throwable cause)

Construct an instance with the provided properties.

Parameters:

message - A text message describing the reason.

cause - the cause.

ConversionException

public ConversionException(String message,
 org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record,
 Throwable cause)

Construct an instance with the provided properties.

Parameters:

message - A text message describing the reason.

record - the consumer record.

cause - the cause.

Since:

2.7.2

ConversionException

public ConversionException(String message,
 List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records,
 Throwable cause)

Construct an instance with the provided properties.

Parameters:

message - A text message describing the reason.

records - the consumer records.

cause - the cause.

Since:

2.7.2

ConversionException

public ConversionException(String message,
 org.springframework.messaging.Message<?> msg,
 Throwable cause)

Construct an instance with the provided properties.

Parameters:

message - A text message describing the reason.

msg - a Message converted from a consumer record.

cause - the cause.

Since:

2.7.2

Method Details

getRecord

public @Nullable org.apache.kafka.clients.consumer.ConsumerRecord<?,?> getRecord()

Return the consumer record, if available.

Returns:

the record.

Since:

2.7.2

getRecords

public List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> getRecords()

Return the consumer record, if available.

Returns:

the record.

Since:

2.7.2

getMsg

public @Nullable org.springframework.messaging.Message<?> getMsg()

Return the Message, if available.

Returns:

the message.

Since:

2.7.2