Package io.streamthoughts.azkarra.runtime.interceptors

Class WaitForSourceTopicsInterceptor

java.lang.Object

io.streamthoughts.azkarra.runtime.interceptors.WaitForSourceTopicsInterceptor

All Implemented Interfaces:

StreamsLifecycleInterceptor

public class WaitForSourceTopicsInterceptor
extends Object
implements StreamsLifecycleInterceptor

This StreamsLifecycleInterceptor waits for source topics to be created before starting the streams instance. Kafka Streams fails if one of the source topic is missing (error: INCOMPLETE_SOURCE_TOPIC_METADATA);

Constructor Summary

Constructors

Constructor	Description
WaitForSourceTopicsInterceptor()	Creates a new WaitForSourceTopicsInterceptor instance.
WaitForSourceTopicsInterceptor(org.apache.kafka.clients.admin.AdminClient adminClient)	Creates a new WaitForSourceTopicsInterceptor instance.

Method Summary

Modifier and Type	Method	Description
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

onStop

Constructor Detail

WaitForSourceTopicsInterceptor

public WaitForSourceTopicsInterceptor()

Creates a new WaitForSourceTopicsInterceptor instance.

WaitForSourceTopicsInterceptor

public WaitForSourceTopicsInterceptor(org.apache.kafka.clients.admin.AdminClient adminClient)

Creates a new WaitForSourceTopicsInterceptor instance.

Parameters:

adminClient - the AdminClient to be used.

Method Detail

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.