Method Detail

• handle

  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.

  Parameters:

  record - The record that failed to produce

  exception - The exception that occurred during production

• handleSerializationException

  default ProductionExceptionHandler.ProductionExceptionHandlerResponse handleSerializationException(org.apache.kafka.clients.producer.ProducerRecord record,
                                                                                                     Exception exception)

  Handles serialization exception and determine if the process should continue. The default implementation is to fail the process.

  Parameters:

  record - the record that failed to serialize

  exception - the exception that occurred during serialization