Package io.streamthoughts.azkarra.runtime.interceptors

Class AutoCreateTopicsInterceptorConfig

java.lang.Object

io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig

public class AutoCreateTopicsInterceptorConfig
extends Object

The configuration class for AutoCreateTopicsInterceptor.

Field Summary

Fields

Modifier and Type	Field	Description
static String	AUTO_CREATE_TOPICS_CONFIGS_CONFIG	auto.create.topics.configs
static String	AUTO_CREATE_TOPICS_ENABLE_CONFIG	auto.create.topics.enable
static String	AUTO_CREATE_TOPICS_NUM_PARTITIONS_CONFIG	auto.create.topics.num.partitions
static int	AUTO_CREATE_TOPICS_NUM_PARTITIONS_DEFAULT
static String	AUTO_CREATE_TOPICS_REPLICATION_FACTOR_CONFIG	auto.create.topics.replication.factor
static int	AUTO_CREATE_TOPICS_REPLICATION_FACTOR_DEFAULT
static String	AUTO_DELETE_TOPICS_ENABLE_CONFIG	auto.delete.topics.enable

Constructor Summary

Constructors

Constructor	Description
AutoCreateTopicsInterceptorConfig(Conf originals)	Creates a new AutoCreateTopicsInterceptorConfig instance.

Method Summary

Modifier and Type	Method	Description
Map<String,String>	getAutoCreateTopicsConfigs()	Get additional properties that should be should be set for creating topics.
int	getAutoCreateTopicsNumPartition()	Get the default number of partitions that should be set for creating topics.
short	getAutoCreateTopicsReplicationFactor()	Get the default replication factor that should be should be set for creating topics.
boolean	isAutoDeleteTopicsEnable()	Get if topics should be automatically deleted once the streams is closed.
Conf	originals()

Methods inherited from class java.lang.Object

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

Field Detail

AUTO_CREATE_TOPICS_ENABLE_CONFIG

public static String AUTO_CREATE_TOPICS_ENABLE_CONFIG

auto.create.topics.enable

AUTO_DELETE_TOPICS_ENABLE_CONFIG

public static String AUTO_DELETE_TOPICS_ENABLE_CONFIG

auto.delete.topics.enable

AUTO_CREATE_TOPICS_NUM_PARTITIONS_CONFIG

public static String AUTO_CREATE_TOPICS_NUM_PARTITIONS_CONFIG

auto.create.topics.num.partitions

AUTO_CREATE_TOPICS_NUM_PARTITIONS_DEFAULT

public static int AUTO_CREATE_TOPICS_NUM_PARTITIONS_DEFAULT

AUTO_CREATE_TOPICS_REPLICATION_FACTOR_CONFIG

public static String AUTO_CREATE_TOPICS_REPLICATION_FACTOR_CONFIG

auto.create.topics.replication.factor

AUTO_CREATE_TOPICS_REPLICATION_FACTOR_DEFAULT

public static int AUTO_CREATE_TOPICS_REPLICATION_FACTOR_DEFAULT

AUTO_CREATE_TOPICS_CONFIGS_CONFIG

public static String AUTO_CREATE_TOPICS_CONFIGS_CONFIG

auto.create.topics.configs

Constructor Detail

AutoCreateTopicsInterceptorConfig

public AutoCreateTopicsInterceptorConfig(Conf originals)

Creates a new AutoCreateTopicsInterceptorConfig instance.

Parameters:

originals - the Conf instance.

Method Detail

getAutoCreateTopicsNumPartition

public int getAutoCreateTopicsNumPartition()

Get the default number of partitions that should be set for creating topics.

getAutoCreateTopicsReplicationFactor

public short getAutoCreateTopicsReplicationFactor()

Get the default replication factor that should be should be set for creating topics.

getAutoCreateTopicsConfigs

public Map<String,String> getAutoCreateTopicsConfigs()

Get additional properties that should be should be set for creating topics.

isAutoDeleteTopicsEnable

public boolean isAutoDeleteTopicsEnable()

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

originals

public Conf originals()