Package org.apache.kafka.streams

Class StreamsConfig.InternalConfig

java.lang.Object

org.apache.kafka.streams.StreamsConfig.InternalConfig

Enclosing class:

StreamsConfig

public static class StreamsConfig.InternalConfig
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ASSIGNMENT_LISTENER
static final String	EMIT_INTERVAL_MS_KSTREAMS_OUTER_JOIN_SPURIOUS_RESULTS_FIX
static final String	EMIT_INTERVAL_MS_KSTREAMS_WINDOWED_AGGREGATION
static final String	INTERNAL_TASK_ASSIGNOR_CLASS
static final String	IQ_CONSISTENCY_OFFSET_VECTOR_ENABLED
static final String	PROCESSING_THREADS_ENABLED
static final String	REFERENCE_CONTAINER_PARTITION_ASSIGNOR
static final String	STATE_UPDATER_ENABLED
static final String	TOPIC_PREFIX_ALTERNATIVE

Constructor Summary

Constructors

Constructor	Description
InternalConfig()

Method Summary

Modifier and Type	Method	Description
static boolean	getBoolean(Map<String,Object> configs, String key, boolean defaultValue)
static long	getLong(Map<String,Object> configs, String key, long defaultValue)
static String	getString(Map<String,Object> configs, String key, String defaultValue)
static boolean	processingThreadsEnabled(Map<String,Object> configs)
static boolean	stateUpdaterEnabled(Map<String,Object> configs)

Methods inherited from class java.lang.Object

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

Field Details

INTERNAL_TASK_ASSIGNOR_CLASS

public static final String INTERNAL_TASK_ASSIGNOR_CLASS

See Also:

• Constant Field Values

REFERENCE_CONTAINER_PARTITION_ASSIGNOR

public static final String REFERENCE_CONTAINER_PARTITION_ASSIGNOR

See Also:

• Constant Field Values

ASSIGNMENT_LISTENER

public static final String ASSIGNMENT_LISTENER

See Also:

• Constant Field Values

EMIT_INTERVAL_MS_KSTREAMS_OUTER_JOIN_SPURIOUS_RESULTS_FIX

public static final String EMIT_INTERVAL_MS_KSTREAMS_OUTER_JOIN_SPURIOUS_RESULTS_FIX

See Also:

• Constant Field Values

EMIT_INTERVAL_MS_KSTREAMS_WINDOWED_AGGREGATION

public static final String EMIT_INTERVAL_MS_KSTREAMS_WINDOWED_AGGREGATION

See Also:

• Constant Field Values

IQ_CONSISTENCY_OFFSET_VECTOR_ENABLED

public static final String IQ_CONSISTENCY_OFFSET_VECTOR_ENABLED

See Also:

• Constant Field Values

TOPIC_PREFIX_ALTERNATIVE

public static final String TOPIC_PREFIX_ALTERNATIVE

See Also:

• Constant Field Values

STATE_UPDATER_ENABLED

public static final String STATE_UPDATER_ENABLED

See Also:

• Constant Field Values

PROCESSING_THREADS_ENABLED

public static final String PROCESSING_THREADS_ENABLED

See Also:

• Constant Field Values

Constructor Details

InternalConfig

public InternalConfig()

Method Details

stateUpdaterEnabled

public static boolean stateUpdaterEnabled(Map<String,Object> configs)

processingThreadsEnabled

public static boolean processingThreadsEnabled(Map<String,Object> configs)

getBoolean

public static boolean getBoolean(Map<String,Object> configs,
 String key,
 boolean defaultValue)

getLong

public static long getLong(Map<String,Object> configs,
 String key,
 long defaultValue)

getString

public static String getString(Map<String,Object> configs,
 String key,
 String defaultValue)