Package io.streamthoughts.azkarra.runtime.interceptors

Class KafkaBrokerReadyInterceptor

java.lang.Object

io.streamthoughts.azkarra.runtime.interceptors.KafkaBrokerReadyInterceptor

All Implemented Interfaces:

Configurable, StreamsLifecycleInterceptor

public class KafkaBrokerReadyInterceptor
extends Object
implements StreamsLifecycleInterceptor, Configurable

Constructor Summary

Constructors

Constructor	Description
KafkaBrokerReadyInterceptor()

Method Summary

Modifier and Type	Method	Description
void	configure(Conf configs)	Configures this instance with the specified Conf.
void	onStart(StreamsLifecycleContext context, StreamsLifecycleChain chain)	Intercepts the streams instance before being started.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.streamthoughts.azkarra.api.StreamsLifecycleInterceptor

name, onStop

Constructor Detail

KafkaBrokerReadyInterceptor

public KafkaBrokerReadyInterceptor()

Method Detail

configure

public void configure(Conf configs)

Configures this instance with the specified Conf.

Specified by:

configure in interface Configurable

Parameters:

configs - the Conf instance used to configure this instance.

onStart

public void onStart(StreamsLifecycleContext context,
                    StreamsLifecycleChain chain)

Intercepts the streams instance before being started.

Specified by:

onStart in interface StreamsLifecycleInterceptor

chain - the StreamsLifecycleChain instance.