Class RRMConfig.KafkaConfig

  • Enclosing class:
    RRMConfig

    public class RRMConfig.KafkaConfig
    extends Object
    uCentral Kafka configuration.
    • Field Detail

      • bootstrapServer

        public String bootstrapServer
        Kafka bootstrap host:port, or empty to disable (KAFKACONFIG_BOOTSTRAPSERVER)
      • stateTopic

        public String stateTopic
        Kafka topic holding uCentral state (KAFKACONFIG_STATETOPIC)
      • wifiScanTopic

        public String wifiScanTopic
        Kafka topic holding uCentral wifi scan results (KAFKACONFIG_WIFISCANTOPIC)
      • serviceEventsTopic

        public String serviceEventsTopic
        Kafka topic holding uCentral microservice events. Used for detecting API keys and internal endpoints. (KAFKACONFIG_SERVICEEVENTSTOPIC)
      • groupId

        public String groupId
        Kafka consumer group ID (KAFKACONFIG_GROUPID)
      • autoOffsetReset

        public String autoOffsetReset
        Kafka "auto.offset.reset" config ["earliest", "latest"] (KAFKACONFIG_AUTOOFFSETRESET)
      • pollTimeoutMs

        public long pollTimeoutMs
        Kafka consumer poll timeout duration, in ms (KAFKACONFIG_POLLTIMEOUTMS)
    • Constructor Detail

      • KafkaConfig

        public KafkaConfig()