public class DefaultProductionExceptionHandler extends Object implements ProductionExceptionHandler
ProductionExceptionHandler
that always instructs streams to fail when an exception
happens while attempting to produce result records.ProductionExceptionHandler.ProductionExceptionHandlerResponse
Constructor and Description |
---|
DefaultProductionExceptionHandler() |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs) |
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.
|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handleSerializationException
public ProductionExceptionHandler.ProductionExceptionHandlerResponse handle(org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]> record, Exception exception)
ProductionExceptionHandler
handle
in interface ProductionExceptionHandler
record
- The record that failed to produceexception
- The exception that occurred during production