public interface ProductionExceptionHandler
extends org.apache.kafka.common.Configurable
Modifier and Type | Interface and Description |
---|---|
static class |
ProductionExceptionHandler.ProductionExceptionHandlerResponse |
Modifier and Type | Method and Description |
---|---|
ProductionExceptionHandler.ProductionExceptionHandlerResponse |
handle(org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]> record,
Exception exception)
Inspect a record that we attempted to produce, and the exception that resulted
from attempting to produce it and determine whether or not to continue processing.
|
default ProductionExceptionHandler.ProductionExceptionHandlerResponse |
handleSerializationException(org.apache.kafka.clients.producer.ProducerRecord record,
Exception exception)
Handles serialization exception and determine if the process should continue.
|
ProductionExceptionHandler.ProductionExceptionHandlerResponse handle(org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]> record, Exception exception)
record
- The record that failed to produceexception
- The exception that occurred during productiondefault ProductionExceptionHandler.ProductionExceptionHandlerResponse handleSerializationException(org.apache.kafka.clients.producer.ProducerRecord record, Exception exception)
record
- the record that failed to serializeexception
- the exception that occurred during serialization