From 52f4980bc2f587e3f3cfe3328f5d9143bcff13ab Mon Sep 17 00:00:00 2001 From: Prune Sebastien THOMAS Date: Tue, 1 Mar 2016 14:38:12 -0500 Subject: [PATCH] parsed with gofmt closes #776 --- CHANGELOG.md | 1 + plugins/inputs/kafka_consumer/kafka_consumer.go | 8 ++++---- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 8632e7cb6..2eb9fa652 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -13,6 +13,7 @@ - [#778](https://github.com/influxdata/telegraf/pull/778): Adding a TCP input listener. - [#797](https://github.com/influxdata/telegraf/issues/797): Provide option for persistent MQTT consumer client sessions. - [#799](https://github.com/influxdata/telegraf/pull/799): Add number of threads for procstat input plugin. Thanks @titilambert! +- [#776](https://github.com/influxdata/telegraf/pull/776): Add Zookeeper chroot option to kafka_consumer. Thanks @prune998! ### Bugfixes - [#748](https://github.com/influxdata/telegraf/issues/748): Fix sensor plugin split on ":" 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