Uses of Interface
io.streamthoughts.azkarra.api.StreamsExecutionEnvironmentAware
-
-
Uses of StreamsExecutionEnvironmentAware in io.streamthoughts.azkarra.runtime.context.internal
Classes in io.streamthoughts.azkarra.runtime.context.internal that implement StreamsExecutionEnvironmentAware Modifier and Type Class Description class
ClassLoaderAwareKafkaStreamsFactory
static class
ContextAwareApplicationIdBuilderSupplier.DelegateApplicationIdBuilder
A delegatingKafkaStreamsFactory
which is notConfigurable
.static class
ContextAwareKafkaStreamsFactorySupplier.DelegateKafkaStreamsFactory
A delegatingKafkaStreamsFactory
which is notConfigurable
.static class
ContextAwareThreadExceptionHandlerSupplier.DelegateStreamThreadExceptionHandler
A delegatingStreamThreadExceptionHandler
which is notConfigurable
.static class
ContextAwareTopologySupplier.ClassLoaderAwareTopologyProvider
A delegatingTopologyProvider
which is notConfigurable
.class
DelegatingExecutionEnvironmentAware<T>
A delegatingStreamsExecutionEnvironmentAware
implementation. -
Uses of StreamsExecutionEnvironmentAware in io.streamthoughts.azkarra.runtime.interceptors
Classes in io.streamthoughts.azkarra.runtime.interceptors that implement StreamsExecutionEnvironmentAware Modifier and Type Class Description class
CompositeStreamsInterceptor
-
Uses of StreamsExecutionEnvironmentAware in io.streamthoughts.azkarra.runtime.streams
Classes in io.streamthoughts.azkarra.runtime.streams that implement StreamsExecutionEnvironmentAware Modifier and Type Class Description class
DefaultApplicationIdBuilder
The defaultApplicationIdBuilder
implementation. -
Uses of StreamsExecutionEnvironmentAware in io.streamthoughts.azkarra.runtime.streams.errors
Classes in io.streamthoughts.azkarra.runtime.streams.errors that implement StreamsExecutionEnvironmentAware Modifier and Type Class Description class
CloseKafkaStreamsOnThreadException
Closes immediately theKafkaStreams
instance when a StreamThread abruptly terminates due to an uncaught exception.
-