Package io.streamthoughts.azkarra.runtime.streams.errors

Class RestartKafkaStreamsOnThreadException

java.lang.Object

io.streamthoughts.azkarra.runtime.streams.errors.RestartKafkaStreamsOnThreadException

All Implemented Interfaces:

StreamThreadExceptionHandler

public class RestartKafkaStreamsOnThreadException
extends Object
implements StreamThreadExceptionHandler

Restarts the KafkaStreams instance when a StreamThread abruptly terminates due to an uncaught exception.

Constructor Summary

Constructors

Constructor	Description
RestartKafkaStreamsOnThreadException()

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RestartKafkaStreamsOnThreadException

public RestartKafkaStreamsOnThreadException()

Method Detail

handle

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

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

Specified by:

handle in interface StreamThreadExceptionHandler

Parameters:

container - the streams container.

streamThread - the thread.

e - the exception.