Class KafkaProducerException

All Implemented Interfaces:
Serializable

public class KafkaProducerException extends KafkaException
Exceptions when producing.
Author:
Gary Russell
See Also:
  • Constructor Details

    • KafkaProducerException

      public KafkaProducerException(org.apache.kafka.clients.producer.ProducerRecord<?,?> failedProducerRecord, String message, Throwable cause)
      Construct an instance with the provided properties.
      Parameters:
      failedProducerRecord - the producer record.
      message - the message.
      cause - the cause.
  • Method Details

    • getFailedProducerRecord

      public <K, V> org.apache.kafka.clients.producer.ProducerRecord<K,V> getFailedProducerRecord()
      Return the failed producer record.
      Type Parameters:
      K - the key type.
      V - the value type.
      Returns:
      the record.
      Since:
      2.5