Package io.streamthoughts.azkarra.runtime.interceptors

Class AutoCreateTopicsInterceptor

java.lang.Object

io.streamthoughts.azkarra.api.components.BaseComponentModule

io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptor

All Implemented Interfaces:

ComponentFactoryAware, ConfigurableComponentFactory, Configurable, StreamsLifecycleInterceptor

public class AutoCreateTopicsInterceptor
extends BaseComponentModule
implements StreamsLifecycleInterceptor, Configurable

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	configure(Conf configuration)	Configures this instance with the specified Conf.
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	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	setTopicConfigs(Map<String,String> topicConfigs)
void	setTopics(Collection<org.apache.kafka.clients.admin.NewTopic> topics)	Sets the list of new topics to create.

Methods inherited from class io.streamthoughts.azkarra.api.components.BaseComponentModule

getComponentFactory, getConfiguration, setComponentFactory

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.components.ConfigurableComponentFactory

getAllComponents, getAllComponents, getAllComponents, getAllComponents, getComponent, getComponent, getComponent, getComponent

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

configure

public void configure(Conf configuration)

Configures this instance with the specified Conf.

Specified by:

configure in interface Configurable

Overrides:

configure in class BaseComponentModule

Parameters:

configuration - 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.

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.

setTopicConfigs

public void setTopicConfigs(Map<String,String> topicConfigs)

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.