Package io.streamthoughts.azkarra.runtime.interceptors

Class AutoCreateTopicsInterceptor

java.lang.Object

io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptor

All Implemented Interfaces:

StreamsLifecycleInterceptor

public class AutoCreateTopicsInterceptor
extends Object
implements StreamsLifecycleInterceptor

This StreamsLifecycleInterceptor create both topics source and sink before starting the streams instance. Optionally, this interceptor can also be used to automatically delete all topics used by the applications when it's closed. This interceptor is state-full and thus a new instance must be created for each topology.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	onStart(StreamsLifecycleContext context, StreamsLifecycleChain chain)	Intercepts the streams instance before being started.
void	onStop(StreamsLifecycleContext context, StreamsLifecycleChain chain)	Intercepts the streams instance before being stopped.
void	setConfigs(Map<String,String> configs)
void	setDeleteTopicsOnStreamsClosed(boolean delete)	Sets if topics should be automatically deleted once the streams is closed.
void	setNumPartitions(int numPartitions)	Sets the default number of partitions uses for creating topics.
void	setReplicationFactor(short replicationFactor)	Sets the default replication factor uses for creating topics.
void	setTopics(Collection<org.apache.kafka.clients.admin.NewTopic> topics)	Sets the list of new topics to create.

Methods inherited from class java.lang.Object

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

Constructor Detail

AutoCreateTopicsInterceptor

public AutoCreateTopicsInterceptor()

Creates a new AutoCreateTopicsInterceptor instance.

AutoCreateTopicsInterceptor

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

Creates a new AutoCreateTopicsInterceptor 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.

onStop

public void onStop(StreamsLifecycleContext context,
                   StreamsLifecycleChain chain)

Intercepts the streams instance before being stopped.

Specified by:

onStop in interface StreamsLifecycleInterceptor

chain - the StreamsLifecycleChain instance.

setReplicationFactor

public void setReplicationFactor(short replicationFactor)

Sets the default replication factor uses for creating topics.

Parameters:

replicationFactor - the replication factor.

setNumPartitions

public void setNumPartitions(int numPartitions)

Sets the default number of partitions uses for creating topics.

Parameters:

numPartitions - the number of partitions.

setTopics

public void setTopics(Collection<org.apache.kafka.clients.admin.NewTopic> topics)

Sets the list of new topics to create.

Parameters:

topics - the list of NewTopic instances.

setConfigs

public void setConfigs(Map<String,String> configs)

setDeleteTopicsOnStreamsClosed

public void setDeleteTopicsOnStreamsClosed(boolean delete)

Sets if topics should be automatically deleted once the streams is closed.

Parameters:

delete - true to enable, otherwise false.