org.apache.kafka.streams.errors

Interface StreamsUncaughtExceptionHandler

public interface StreamsUncaughtExceptionHandler

Nested Class Summary

Nested Classes

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

Method Summary

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

Method Detail

handle

StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse handle(Throwable exception)

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

Parameters:

exception - the actual exception