Package io.streamthoughts.azkarra.api

Interface StreamsLifecycleInterceptor

All Known Implementing Classes:

AutoCreateTopicsInterceptor, ClassloadingIsolationInterceptor, CompositeStreamsInterceptor, MeterKafkaStreamsInterceptor, MonitoringStreamsInterceptor, WaitForSourceTopicsInterceptor

public interface StreamsLifecycleInterceptor

An interface that allows to intercept a KafkaStreams instance before being started or stopped.

Method Summary

Modifier and Type	Method	Description
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 - the StreamsLifecycleChain instance.

onStop

default void onStop(StreamsLifecycleContext context,
                    StreamsLifecycleChain chain)

Intercepts the streams instance before being stopped.

Parameters:

chain - the StreamsLifecycleChain instance.