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

    Modifier and Type Method Description
    org.apache.kafka.clients.producer.ProducerRecord<?,​?> getRecord()  
    java.lang.String toString()  

    Methods inherited from class org.springframework.messaging.MessagingException

    getFailedMessage

    Methods inherited from class org.springframework.core.NestedRuntimeException

    contains, getMessage, getMostSpecificCause, getRootCause

    Methods inherited from class java.lang.Throwable

    addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
  • Constructor Details

    • KafkaSendFailureException

      public KafkaSendFailureException​(org.springframework.messaging.Message<?> message, org.apache.kafka.clients.producer.ProducerRecord<?,​?> record, java.lang.Throwable cause)
  • Method Details

    • getRecord

      public org.apache.kafka.clients.producer.ProducerRecord<?,​?> getRecord()
    • toString

      public java.lang.String toString()
      Overrides:
      toString in class org.springframework.messaging.MessagingException