public static class StreamsConfig.InternalConfig extends Object
Modifier and Type | Field and Description |
---|---|
static String |
ASSIGNMENT_LISTENER |
static String |
EMIT_INTERVAL_MS_KSTREAMS_OUTER_JOIN_SPURIOUS_RESULTS_FIX |
static String |
EMIT_INTERVAL_MS_KSTREAMS_WINDOWED_AGGREGATION |
static String |
INTERNAL_TASK_ASSIGNOR_CLASS |
static String |
IQ_CONSISTENCY_OFFSET_VECTOR_ENABLED |
static String |
REFERENCE_CONTAINER_PARTITION_ASSIGNOR |
static String |
STATE_UPDATER_ENABLED |
static String |
TOPIC_PREFIX_ALTERNATIVE |
Constructor and Description |
---|
InternalConfig() |
Modifier and Type | Method and 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) |
public static final String INTERNAL_TASK_ASSIGNOR_CLASS
public static final String REFERENCE_CONTAINER_PARTITION_ASSIGNOR
public static final String ASSIGNMENT_LISTENER
public static final String EMIT_INTERVAL_MS_KSTREAMS_OUTER_JOIN_SPURIOUS_RESULTS_FIX
public static final String EMIT_INTERVAL_MS_KSTREAMS_WINDOWED_AGGREGATION
public static final String IQ_CONSISTENCY_OFFSET_VECTOR_ENABLED
public static final String TOPIC_PREFIX_ALTERNATIVE
public static final String STATE_UPDATER_ENABLED