java.lang.Object

org.apache.kafka.streams.StreamsConfig.InternalConfig

Enclosing class:: StreamsConfig

public static class StreamsConfig.InternalConfigextends 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_CONSUMER_WRAPPER

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
- INTERNAL_CONSUMER_WRAPPER
  public static final String INTERNAL_CONSUMER_WRAPPER
  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)

Class StreamsConfig.InternalConfig

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Details

INTERNAL_TASK_ASSIGNOR_CLASS

REFERENCE_CONTAINER_PARTITION_ASSIGNOR

ASSIGNMENT_LISTENER

INTERNAL_CONSUMER_WRAPPER

EMIT_INTERVAL_MS_KSTREAMS_OUTER_JOIN_SPURIOUS_RESULTS_FIX

EMIT_INTERVAL_MS_KSTREAMS_WINDOWED_AGGREGATION

IQ_CONSISTENCY_OFFSET_VECTOR_ENABLED

TOPIC_PREFIX_ALTERNATIVE

STATE_UPDATER_ENABLED

PROCESSING_THREADS_ENABLED

Constructor Details

InternalConfig

Method Details

stateUpdaterEnabled

processingThreadsEnabled

getBoolean

getLong

getString