Package io.streamthoughts.azkarra.runtime.config

Class AzkarraContextConfig

java.lang.Object

io.streamthoughts.azkarra.runtime.config.AzkarraContextConfig

public class AzkarraContextConfig
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static String	AUTO_CREATE_TOPICS_CONFIGS_CONFIG	Deprecated. use AutoCreateTopicsInterceptorConfig.AUTO_CREATE_TOPICS_CONFIGS_CONFIG
static String	AUTO_CREATE_TOPICS_ENABLE_CONFIG	Deprecated. use AutoCreateTopicsInterceptorConfig.AUTO_CREATE_TOPICS_ENABLE_CONFIG
static String	AUTO_CREATE_TOPICS_NUM_PARTITIONS_CONFIG	Deprecated. use AutoCreateTopicsInterceptorConfig.AUTO_CREATE_TOPICS_NUM_PARTITIONS_CONFIG
static String	AUTO_CREATE_TOPICS_REPLICATION_FACTOR_CONFIG	Deprecated. use AutoCreateTopicsInterceptorConfig.AUTO_CREATE_TOPICS_REPLICATION_FACTOR_CONFIG
static String	AUTO_DELETE_TOPICS_ENABLE_CONFIG	Deprecated. use AutoCreateTopicsInterceptorConfig.AUTO_DELETE_TOPICS_ENABLE_CONFIG
static String	DEFAULT_STREAM_THREAD_EXCEPTION_HANDLER
static String	WAIT_FOR_TOPICS_ENABLE_CONFIG	Deprecated. use WaitForSourceTopicsInterceptorConfig.WAIT_FOR_TOPICS_ENABLE_CONFIG

Constructor Summary

Constructors

Constructor	Description
AzkarraContextConfig(Conf configs)	Creates a new AzkarraContextConfig instance.

Method Summary

Modifier and Type	Method	Description
AzkarraContextConfig	addConfiguration(Conf configs)
Conf	configs()
Map<String,String>	getAutoCreateTopicsConfigs()
int	getAutoCreateTopicsNumPartition()
short	getAutoCreateTopicsReplicationFactor()
StreamThreadExceptionHandler	getDefaultStreamsThreadExceptionHandler()
boolean	isAutoCreateTopicsEnable()
boolean	isAutoDeleteTopicsEnable()
boolean	isWaitForTopicsEnable()

Methods inherited from class java.lang.Object

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

Field Detail

WAIT_FOR_TOPICS_ENABLE_CONFIG

@Deprecated
public static String WAIT_FOR_TOPICS_ENABLE_CONFIG

Deprecated.

use WaitForSourceTopicsInterceptorConfig.WAIT_FOR_TOPICS_ENABLE_CONFIG

This static field will be removed in a future version.

AUTO_CREATE_TOPICS_ENABLE_CONFIG

@Deprecated
public static String AUTO_CREATE_TOPICS_ENABLE_CONFIG

Deprecated.

use AutoCreateTopicsInterceptorConfig.AUTO_CREATE_TOPICS_ENABLE_CONFIG

This static field will be removed in a future version.

AUTO_DELETE_TOPICS_ENABLE_CONFIG

@Deprecated
public static String AUTO_DELETE_TOPICS_ENABLE_CONFIG

Deprecated.

use AutoCreateTopicsInterceptorConfig.AUTO_DELETE_TOPICS_ENABLE_CONFIG

This static field will be removed in a future version.

AUTO_CREATE_TOPICS_NUM_PARTITIONS_CONFIG

@Deprecated
public static String AUTO_CREATE_TOPICS_NUM_PARTITIONS_CONFIG

Deprecated.

use AutoCreateTopicsInterceptorConfig.AUTO_CREATE_TOPICS_NUM_PARTITIONS_CONFIG

This static field will be removed in a future version.

AUTO_CREATE_TOPICS_REPLICATION_FACTOR_CONFIG

@Deprecated
public static String AUTO_CREATE_TOPICS_REPLICATION_FACTOR_CONFIG

Deprecated.

use AutoCreateTopicsInterceptorConfig.AUTO_CREATE_TOPICS_REPLICATION_FACTOR_CONFIG

This static field will be removed in a future version.

AUTO_CREATE_TOPICS_CONFIGS_CONFIG

@Deprecated
public static String AUTO_CREATE_TOPICS_CONFIGS_CONFIG

Deprecated.

use AutoCreateTopicsInterceptorConfig.AUTO_CREATE_TOPICS_CONFIGS_CONFIG

This static field will be removed in a future version.

DEFAULT_STREAM_THREAD_EXCEPTION_HANDLER

public static String DEFAULT_STREAM_THREAD_EXCEPTION_HANDLER

Constructor Detail

AzkarraContextConfig

public AzkarraContextConfig(Conf configs)

Creates a new AzkarraContextConfig instance.

Parameters:

configs - the Conf instance.

Method Detail

isAutoDeleteTopicsEnable

public boolean isAutoDeleteTopicsEnable()

isAutoCreateTopicsEnable

public boolean isAutoCreateTopicsEnable()

getDefaultStreamsThreadExceptionHandler

public StreamThreadExceptionHandler getDefaultStreamsThreadExceptionHandler()

getAutoCreateTopicsNumPartition

public int getAutoCreateTopicsNumPartition()

getAutoCreateTopicsReplicationFactor

public short getAutoCreateTopicsReplicationFactor()

getAutoCreateTopicsConfigs

public Map<String,String> getAutoCreateTopicsConfigs()

isWaitForTopicsEnable

public boolean isWaitForTopicsEnable()

addConfiguration

public AzkarraContextConfig addConfiguration(Conf configs)

configs

public Conf configs()