Field Detail

• 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

Constructor Detail

• InternalConfig

  public InternalConfig()

Method Detail

• 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)