Package org.apache.kafka.streams.errors

Interface StreamsUncaughtExceptionHandler

public interface StreamsUncaughtExceptionHandler

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse	Enumeration that describes the response from the exception handler.

Method Summary

Modifier and Type	Method	Description
StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse	handle(Throwable exception)	Inspect the exception received in a stream thread and respond with an action.

Method Details

handle

StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse handle(Throwable exception)

Inspect the exception received in a stream thread and respond with an action.

Parameters:

exception - The actual exception.

Returns:

Whether to replace the failed thread, or to shut down the client or the whole application.