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() |
selfLogcontains, getMessage, getMostSpecificCause, getRootCausepublic 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.