diff --git a/plugins/inputs/kafka_consumer/kafka_consumer.go b/plugins/inputs/kafka_consumer/kafka_consumer.go index 0d2a49f89..07c87199f 100644 --- a/plugins/inputs/kafka_consumer/kafka_consumer.go +++ b/plugins/inputs/kafka_consumer/kafka_consumer.go @@ -14,11 +14,11 @@ import ( ) type Kafka struct { - ConsumerGroup string - Topics []string - ZookeeperPeers []string + ConsumerGroup string + Topics []string + ZookeeperPeers []string ZookeeperChroot string - Consumer *consumergroup.ConsumerGroup + Consumer *consumergroup.ConsumerGroup // Legacy metric buffer support MetricBuffer int