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.

Author:

Gary Russell

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.kafka.KafkaException

KafkaException.Level

Constructor Summary

Constructors

Constructor	Description
ConversionException(String message, 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, Message<?> msg, Throwable cause)	Construct an instance with the provided properties.

Method Summary

Modifier and Type	Method	Description
Message<?>	getMsg()	Return the Message, if available.
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 org.springframework.kafka.KafkaException

selfLog

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

ConversionException

public ConversionException(String message,
 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,
 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

@Nullable
public 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

@Nullable
public Message<?> getMsg()

Return the Message, if available.

Returns:

the message.

Since:

2.7.2