Class KafkaLogConfig

    • Field Detail

      • adminProperties

        protected final Properties adminProperties
      • producerProperties

        protected final Properties producerProperties
      • consumerProperties

        protected final Properties consumerProperties
      • defaultReplicationFactor

        protected final short defaultReplicationFactor
      • disableSubscribe

        protected final Boolean disableSubscribe
      • name

        protected final String name
    • Method Detail

      • getReplicatorFactor

        public short getReplicatorFactor()
      • getDisableSubscribe

        public Boolean getDisableSubscribe()
      • getAdminProperties

        public Properties getAdminProperties()
      • getProducerProperties

        public Properties getProducerProperties()
      • getConsumerProperties

        public Properties getConsumerProperties()
      • normalizeAdminProperties

        protected Properties normalizeAdminProperties​(Properties adminProperties)
      • normalizeProducerProperties

        protected Properties normalizeProducerProperties​(Properties producerProperties)
      • normalizeConsumerProperties

        protected Properties normalizeConsumerProperties​(Properties consumerProperties)
      • createAdminProperties

        protected Properties createAdminProperties​(Properties producerProperties)
      • filterDisplayedProperties

        protected String filterDisplayedProperties​(Properties properties)