Package io.streamthoughts.azkarra.api.streams.errors

Interface StreamThreadExceptionHandler

All Known Implementing Classes:

CloseKafkaStreamsOnThreadException, ContextAwareThreadExceptionHandlerSupplier.DelegateStreamThreadExceptionHandler, LogAndSkipOnThreadException, RestartKafkaStreamsOnThreadException

public interface StreamThreadExceptionHandler

Interface that specifies how to handle an uncaught exception from a StreamThread.

See Also:

Thread.UncaughtExceptionHandler, KafkaStreams.setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler)

Method Summary

Modifier and Type	Method	Description
void	handle(KafkaStreamsContainer container, Thread streamThread, Throwable e)	Method invoked when a StreamThread abruptly terminates due to an uncaught exception.

Method Detail

handle

void handle(KafkaStreamsContainer container,
            Thread streamThread,
            Throwable e)

Method invoked when a StreamThread abruptly terminates due to an uncaught exception.

Parameters:

container - the streams container.

streamThread - the thread.

e - the exception.