Uses of Class
io.streamthoughts.azkarra.api.components.BaseComponentModule
-
-
Uses of BaseComponentModule in io.streamthoughts.azkarra.api.components
Subclasses of BaseComponentModule in io.streamthoughts.azkarra.api.components Modifier and Type Class Description class
ComponentModule<T>
A configurable component supplier which has access to theComponentFactory
. -
Uses of BaseComponentModule in io.streamthoughts.azkarra.metrics.interceptor
Subclasses of BaseComponentModule in io.streamthoughts.azkarra.metrics.interceptor Modifier and Type Class Description class
MeterKafkaStreamsInterceptor
-
Uses of BaseComponentModule in io.streamthoughts.azkarra.metrics.micrometer
Subclasses of BaseComponentModule in io.streamthoughts.azkarra.metrics.micrometer Modifier and Type Class Description class
MeterRegistryFactory
The default factory to build the primaryMeterRegistry
. -
Uses of BaseComponentModule in io.streamthoughts.azkarra.runtime.interceptors
Subclasses of BaseComponentModule in io.streamthoughts.azkarra.runtime.interceptors Modifier and Type Class Description class
AutoCreateTopicsInterceptor
ThisStreamsLifecycleInterceptor
create both topics source and sink before starting the streams instance.class
MonitoringStreamsInterceptor
Interceptor to monitorKafkaStreams
instance. -
Uses of BaseComponentModule in io.streamthoughts.azkarra.runtime.modules
Subclasses of BaseComponentModule in io.streamthoughts.azkarra.runtime.modules Modifier and Type Class Description class
InteractiveQueryServiceModule
-
Uses of BaseComponentModule in io.streamthoughts.examples.azkarra.conditional
Subclasses of BaseComponentModule in io.streamthoughts.examples.azkarra.conditional Modifier and Type Class Description static class
ConditionalStreamsApplication.NormalizeStreamsTopology
-
Uses of BaseComponentModule in io.streamthoughts.examples.azkarra.dependency
Subclasses of BaseComponentModule in io.streamthoughts.examples.azkarra.dependency Modifier and Type Class Description class
ComplexWordCountTopologyModule
AComponentModule
for providing a new @{link ComplexWordCountTopology} instance.
-