Uses of Interface
io.streamthoughts.azkarra.api.streams.errors.StreamThreadExceptionHandler
-
-
Uses of StreamThreadExceptionHandler in io.streamthoughts.azkarra.api.streams.errors
Constructors in io.streamthoughts.azkarra.api.streams.errors with parameters of type StreamThreadExceptionHandler Constructor Description DelegatingUncaughtExceptionHandler(KafkaStreamsContainer container, StreamThreadExceptionHandler handler)
-
Uses of StreamThreadExceptionHandler in io.streamthoughts.azkarra.runtime.context
Methods in io.streamthoughts.azkarra.runtime.context that return StreamThreadExceptionHandler Modifier and Type Method Description StreamThreadExceptionHandler
DefaultStreamThreadExceptionHandlerFactory. get()
-
Uses of StreamThreadExceptionHandler in io.streamthoughts.azkarra.runtime.context.internal
Classes in io.streamthoughts.azkarra.runtime.context.internal that implement StreamThreadExceptionHandler Modifier and Type Class Description static class
ContextAwareThreadExceptionHandlerSupplier.DelegateStreamThreadExceptionHandler
A delegatingStreamThreadExceptionHandler
which is notConfigurable
.Methods in io.streamthoughts.azkarra.runtime.context.internal that return StreamThreadExceptionHandler Modifier and Type Method Description StreamThreadExceptionHandler
ContextAwareThreadExceptionHandlerSupplier. get()
Constructor parameters in io.streamthoughts.azkarra.runtime.context.internal with type arguments of type StreamThreadExceptionHandler Constructor Description ContextAwareThreadExceptionHandlerSupplier(AzkarraContext context, GettableComponent<StreamThreadExceptionHandler> gettable)
-
Uses of StreamThreadExceptionHandler in io.streamthoughts.azkarra.runtime.env
Methods in io.streamthoughts.azkarra.runtime.env that return types with arguments of type StreamThreadExceptionHandler Modifier and Type Method Description Optional<Supplier<StreamThreadExceptionHandler>>
LocalStreamsExecutionEnvironmentFactory. findStreamThreadExceptionHandler(Conf conf, Restriction restriction)
Supplier<StreamThreadExceptionHandler>
LocalStreamsExecutionEnvironment. getStreamThreadExceptionHandler()
Gets theStreamThreadExceptionHandler
.Method parameters in io.streamthoughts.azkarra.runtime.env with type arguments of type StreamThreadExceptionHandler Modifier and Type Method Description LocalStreamsExecutionEnvironment
LocalStreamsExecutionEnvironment. setStreamThreadExceptionHandler(Supplier<StreamThreadExceptionHandler> handler)
Sets theStreamThreadExceptionHandler
invoked when a StreamThread abruptly terminates due to an uncaught exception. -
Uses of StreamThreadExceptionHandler in io.streamthoughts.azkarra.runtime.streams
Method parameters in io.streamthoughts.azkarra.runtime.streams with type arguments of type StreamThreadExceptionHandler Modifier and Type Method Description LocalKafkaStreamsContainerBuilder
LocalKafkaStreamsContainerBuilder. withStreamThreadExceptionHandlers(List<StreamThreadExceptionHandler> handlers)
-
Uses of StreamThreadExceptionHandler in io.streamthoughts.azkarra.runtime.streams.errors
Classes in io.streamthoughts.azkarra.runtime.streams.errors that implement StreamThreadExceptionHandler Modifier and Type Class Description class
CloseKafkaStreamsOnThreadException
Closes immediately theKafkaStreams
instance when a StreamThread abruptly terminates due to an uncaught exception.class
LogAndSkipOnThreadException
Logs and skips exception when a StreamThread abruptly terminates due to an uncaught exception.class
RestartKafkaStreamsOnThreadException
Restarts theKafkaStreams
instance when a StreamThread abruptly terminates due to an uncaught exception.
-