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. |
public ProductionExceptionHandler.ProductionExceptionHandlerResponse handle(org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]> record, Exception exception)
ProductionExceptionHandlerhandle in interface ProductionExceptionHandlerrecord - The record that failed to produceexception - The exception that occurred during production