Use sarama built in support for consumer groups (influxdata#6172)

Gopkg.toml

@@ -18,10 +18,6 @@
   name = "github.com/aws/aws-sdk-go"
   version = "1.15.54"
 
-[[constraint]]
-  name = "github.com/bsm/sarama-cluster"
-  version = "2.1.13"
-
 [[constraint]]
   name = "github.com/couchbase/go-couchbase"
   branch = "master"

Makefile

@@ -1,9 +1,8 @@
-ifeq ($(SHELL), cmd)
-	VERSION := $(shell git describe --exact-match --tags 2>nil)
-	HOME := $(HOMEPATH)
-else ifeq ($(SHELL), sh.exe)
+ifeq ($(OS), Windows_NT)
 	VERSION := $(shell git describe --exact-match --tags 2>nil)
 	HOME := $(HOMEPATH)
+	CGO_ENABLED ?= 0
+	export CGO_ENABLED
 else
 	VERSION := $(shell git describe --exact-match --tags 2>/dev/null)
 endif
@@ -48,7 +47,6 @@ install: telegraf
 	mkdir -p $(DESTDIR)$(PREFIX)/bin/
 	cp telegraf $(DESTDIR)$(PREFIX)/bin/
 
-
 .PHONY: test
 test:
 	go test -short ./...

docs/LICENSE_OF_DEPENDENCIES.md

@@ -14,7 +14,6 @@ following works:
 - github.com/aws/aws-sdk-go [Apache License 2.0](https://github.com/aws/aws-sdk-go/blob/master/LICENSE.txt)
 - github.com/Azure/go-autorest [Apache License 2.0](https://github.com/Azure/go-autorest/blob/master/LICENSE)
 - github.com/beorn7/perks [MIT License](https://github.com/beorn7/perks/blob/master/LICENSE)
-- github.com/bsm/sarama-cluster [MIT License](https://github.com/bsm/sarama-cluster/blob/master/LICENSE)
 - github.com/cenkalti/backoff [MIT License](https://github.com/cenkalti/backoff/blob/master/LICENSE)
 - github.com/cisco-ie/nx-telemetry-proto [Apache License 2.0](https://github.com/cisco-ie/nx-telemetry-proto/blob/master/LICENSE)
 - github.com/couchbase/go-couchbase [MIT License](https://github.com/couchbase/go-couchbase/blob/master/LICENSE)
@@ -139,4 +138,4 @@ following works:
 - gopkg.in/yaml.v2 [Apache License 2.0](https://github.com/go-yaml/yaml/blob/v2.2.2/LICENSE)
 
 ## telegraf used and modified code from these projects
-- github.com/DataDog/datadog-agent [Apache License 2.0](https://github.com/DataDog/datadog-agent/LICENSE)
+- github.com/DataDog/datadog-agent [Apache License 2.0](https://github.com/DataDog/datadog-agent/LICENSE)

plugins/inputs/kafka_consumer/README.md

@@ -10,11 +10,13 @@ and use the old zookeeper connection method.
 
 ```toml
 [[inputs.kafka_consumer]]
-  ## kafka servers
+  ## Kafka brokers.
   brokers = ["localhost:9092"]
-  ## topic(s) to consume
+
+  ## Topics to consume.
   topics = ["telegraf"]
-  ## Add topic as tag if topic_tag is not empty
+
+  ## When set this tag will be added to all metrics with the topic as the value.
   # topic_tag = ""
 
   ## Optional Client id
@@ -37,10 +39,11 @@ and use the old zookeeper connection method.
   # sasl_username = "kafka"
   # sasl_password = "secret"
 
-  ## the name of the consumer group
-  consumer_group = "telegraf_metrics_consumers"
-  ## Offset (must be either "oldest" or "newest")
-  offset = "oldest"
+  ## Name of the consumer group.
+  # consumer_group = "telegraf_metrics_consumers"
+
+  ## Initial offset position; one of "oldest" or "newest".
+  # offset = "oldest"
 
   ## Maximum length of a message to consume, in bytes (default 0/unlimited);
   ## larger messages are dropped