ProcessingExceptionHandler (streams 7.9.5-ce API)

All Superinterfaces:
org.apache.kafka.common.Configurable
All Known Implementing Classes:
LogAndContinueProcessingExceptionHandler, LogAndFailProcessingExceptionHandler
```
public interface ProcessingExceptionHandler
extends org.apache.kafka.common.Configurable
```
An interface that allows user code to inspect a record that has failed processing

Nested Class Summary
Nested Classes
Modifier and Type Interface and Description
static class ProcessingExceptionHandler.ProcessingHandlerResponse

Nested Classes
Modifier and Type	Interface and Description
`static class`	`ProcessingExceptionHandler.ProcessingHandlerResponse`

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`ProcessingExceptionHandler.ProcessingHandlerResponse`	`handle(ErrorHandlerContext context, Record<?,?> record, Exception exception)` Inspect a record and the exception received

Methods inherited from interface org.apache.kafka.common.Configurable
configure

Method Detail

handle

ProcessingExceptionHandler.ProcessingHandlerResponse handle(ErrorHandlerContext context,
                                                            Record<?,?> record,
                                                            Exception exception)

Inspect a record and the exception received

Parameters:: context - processing context metadata; record - record where the exception occurred; exception - the actual exception

Interface ProcessingExceptionHandler

Nested Class Summary

Method Summary

Methods inherited from interface org.apache.kafka.common.Configurable

Method Detail

handle