Package io.streamthoughts.azkarra.api
Interface StreamsLifecycleInterceptor
-
- All Known Implementing Classes:
AutoCreateTopicsInterceptor
,ClassloadingIsolationInterceptor
,CompositeStreamsInterceptor
,KafkaBrokerReadyInterceptor
,MeterKafkaStreamsInterceptor
,MonitoringStreamsInterceptor
,WaitForSourceTopicsInterceptor
public interface StreamsLifecycleInterceptor
An interface that allows to intercept aKafkaStreams
instance before being started or stopped.
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default String
name()
The Interceptor name is mostly used for logging information.default void
onStart(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being started.default void
onStop(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being stopped.
-
-
-
Method Detail
-
onStart
default void onStart(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being started.- Parameters:
chain
- theStreamsLifecycleChain
instance.
-
onStop
default void onStop(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being stopped.- Parameters:
chain
- theStreamsLifecycleChain
instance.
-
name
default String name()
The Interceptor name is mostly used for logging information.- Returns:
- the name of this interceptor.
-
-