Class AzkarraContextConfig


  • public class AzkarraContextConfig
    extends Object
    • Field Detail

      • WAIT_FOR_TOPICS_ENABLE_CONFIG

        public static String WAIT_FOR_TOPICS_ENABLE_CONFIG
      • AUTO_CREATE_TOPICS_ENABLE_CONFIG

        public static String AUTO_CREATE_TOPICS_ENABLE_CONFIG
      • AUTO_DELETE_TOPICS_ENABLE_CONFIG

        public static String AUTO_DELETE_TOPICS_ENABLE_CONFIG
      • AUTO_CREATE_TOPICS_NUM_PARTITIONS_CONFIG

        public static String AUTO_CREATE_TOPICS_NUM_PARTITIONS_CONFIG
      • AUTO_CREATE_TOPICS_REPLICATION_FACTOR_CONFIG

        public static String AUTO_CREATE_TOPICS_REPLICATION_FACTOR_CONFIG
      • AUTO_CREATE_TOPICS_CONFIGS_CONFIG

        public static String AUTO_CREATE_TOPICS_CONFIGS_CONFIG
    • Constructor Detail

      • AzkarraContextConfig

        public AzkarraContextConfig​(Conf configs)
        Creates a new AzkarraContextConfig instance.
        Parameters:
        configs - the Conf instance.
    • Method Detail

      • isAutoDeleteTopicsEnable

        public boolean isAutoDeleteTopicsEnable()
      • isAutoCreateTopicsEnable

        public boolean isAutoCreateTopicsEnable()
      • getAutoCreateTopicsNumPartition

        public int getAutoCreateTopicsNumPartition()
      • getAutoCreateTopicsReplicationFactor

        public short getAutoCreateTopicsReplicationFactor()
      • getAutoCreateTopicsConfigs

        public Map<String,​String> getAutoCreateTopicsConfigs()
      • isWaitForTopicsEnable

        public boolean isWaitForTopicsEnable()
      • configs

        public Conf configs()