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:
java.io.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:
- Serialized Form
-
Constructor Summary
Constructors Constructor Description KafkaSendFailureException(org.springframework.messaging.Message<?> message, org.apache.kafka.clients.producer.ProducerRecord<?,?> record, java.lang.Throwable cause) -
Method Summary
Methods inherited from class org.springframework.core.NestedRuntimeException
contains, getMessage, getMostSpecificCause, getRootCause
-
Constructor Details
-
KafkaSendFailureException
public KafkaSendFailureException(org.springframework.messaging.Message<?> message, org.apache.kafka.clients.producer.ProducerRecord<?,?> record, java.lang.Throwable cause)
-
-
Method Details