org.apache.kafka.streams.errors.DefaultProductionExceptionHandler

public class DefaultProductionExceptionHandler
extends Object
implements ProductionExceptionHandler

ProductionExceptionHandler that always instructs streams to fail when an exception happens while attempting to produce result records.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.kafka.streams.errors.ProductionExceptionHandler
ProductionExceptionHandler.ProductionExceptionHandlerResponse
Constructor Summary

Constructors

Constructor Description

DefaultProductionExceptionHandler()

Method Summary

Modifier and Type	Method	Description
`void`	`configure(Map<String,?> configs)`	Configure this class with the given key-value pairs
`ProductionExceptionHandler.ProductionExceptionHandlerResponse`	`handle(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.

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- DefaultProductionExceptionHandler
  
  public DefaultProductionExceptionHandler()
Method Details
- handle
  
  public ProductionExceptionHandler.ProductionExceptionHandlerResponse handle(ProducerRecord<byte[],byte[]> record, Exception exception)
  
  Description copied from interface: ProductionExceptionHandler
  
  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.
  
  Specified by:
  
  handle in interface ProductionExceptionHandler
  
  Parameters:
  
  record - The record that failed to produce
  
  exception - The exception that occurred during production
- configure
  
  public void configure(Map<String,?> configs)
  
  Description copied from interface: Configurable
  
  Configure this class with the given key-value pairs
  
  Specified by:
  
  configure in interface Configurable

Class DefaultProductionExceptionHandler