public class KafkaSendFailureException
extends org.springframework.messaging.MessagingException
ErrorMessage
when a send fails.Constructor and Description |
---|
KafkaSendFailureException(org.springframework.messaging.Message<?> message,
org.apache.kafka.clients.producer.ProducerRecord<?,?> record,
java.lang.Throwable cause) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.producer.ProducerRecord<?,?> |
getRecord() |
java.lang.String |
toString() |
contains, getMessage, getMostSpecificCause, getRootCause