Class StreamsConfig.InternalConfig

java.lang.Object
org.apache.kafka.streams.StreamsConfig.InternalConfig
Enclosing class:
StreamsConfig

public static class StreamsConfig.InternalConfig extends Object
  • Field Details

  • Constructor Details

    • InternalConfig

      public InternalConfig()
  • Method Details

    • getStateUpdaterEnabled

      public static boolean getStateUpdaterEnabled(Map<String,Object> configs)
    • getProcessingThreadsEnabled

      public static boolean getProcessingThreadsEnabled(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)