public class KafkaProducerException extends KafkaException
KafkaException.Level
Constructor and Description |
---|
KafkaProducerException(org.apache.kafka.clients.producer.ProducerRecord<?,?> failedProducerRecord,
java.lang.String message,
java.lang.Throwable cause)
Construct an instance with the provided properties.
|
Modifier and Type | Method and Description |
---|---|
<K,V> org.apache.kafka.clients.producer.ProducerRecord<K,V> |
getFailedProducerRecord()
Return the failed producer record.
|
org.apache.kafka.clients.producer.ProducerRecord<?,?> |
getProducerRecord()
Deprecated.
in favor of
getFailedProducerRecord() |
selfLog
contains, getMessage, getMostSpecificCause, getRootCause
public KafkaProducerException(org.apache.kafka.clients.producer.ProducerRecord<?,?> failedProducerRecord, java.lang.String message, java.lang.Throwable cause)
failedProducerRecord
- the producer record.message
- the message.cause
- the cause.@Deprecated public org.apache.kafka.clients.producer.ProducerRecord<?,?> getProducerRecord()
getFailedProducerRecord()
public <K,V> org.apache.kafka.clients.producer.ProducerRecord<K,V> getFailedProducerRecord()
K
- the key type.V
- the value type.