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.
|
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 production