Class KafkaSendFailureException
java.lang.Object
java.lang.Throwable
java.lang.Exception
java.lang.RuntimeException
org.springframework.core.NestedRuntimeException
org.springframework.messaging.MessagingException
org.springframework.integration.kafka.support.KafkaSendFailureException
- All Implemented Interfaces:
Serializable
public class KafkaSendFailureException
extends org.springframework.messaging.MessagingException
An exception that is the payload of an
ErrorMessage when a send fails.- Since:
- 5.4
- See Also:
-
Constructor Summary
ConstructorsConstructorDescriptionKafkaSendFailureException(org.springframework.messaging.Message<?> message, org.apache.kafka.clients.producer.ProducerRecord<?, ?> record, Throwable cause) -
Method Summary
Methods inherited from class org.springframework.messaging.MessagingException
getFailedMessageMethods inherited from class org.springframework.core.NestedRuntimeException
contains, getMostSpecificCause, getRootCauseMethods inherited from class java.lang.Throwable
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace
-
Constructor Details
-
KafkaSendFailureException
public KafkaSendFailureException(org.springframework.messaging.Message<?> message, org.apache.kafka.clients.producer.ProducerRecord<?, ?> record, Throwable cause)
-
-
Method Details
-
getRecord
public org.apache.kafka.clients.producer.ProducerRecord<?,?> getRecord() -
toString
- Overrides:
toStringin classorg.springframework.messaging.MessagingException
-