diff --git a/plugins/inputs/kafka_consumer/README.md b/plugins/inputs/kafka_consumer/README.md index d794377fa..24a0efc0f 100644 --- a/plugins/inputs/kafka_consumer/README.md +++ b/plugins/inputs/kafka_consumer/README.md @@ -23,7 +23,7 @@ and use the old zookeeper connection method. offset = "oldest" ## Optional client id - # client_id = "my_client" + # client_id = "Telegraf" ## Optional TLS Config # tls_ca = "/etc/telegraf/ca.pem" diff --git a/plugins/inputs/kafka_consumer/kafka_consumer.go b/plugins/inputs/kafka_consumer/kafka_consumer.go index 72172bcb6..d3791b224 100644 --- a/plugins/inputs/kafka_consumer/kafka_consumer.go +++ b/plugins/inputs/kafka_consumer/kafka_consumer.go @@ -60,7 +60,7 @@ var sampleConfig = ` brokers = ["localhost:9092"] ## topic(s) to consume topics = ["telegraf"] - + ## Optional Client id # client_id = "Telegraf" diff --git a/plugins/outputs/kafka/README.md b/plugins/outputs/kafka/README.md index 00544e99c..562f3fd5d 100644 --- a/plugins/outputs/kafka/README.md +++ b/plugins/outputs/kafka/README.md @@ -11,7 +11,7 @@ This plugin writes to a [Kafka Broker](http://kafka.apache.org/07/quickstart.htm topic = "telegraf" ## Optional client id - # client_id = "my_client" + # client_id = "Telegraf" ## Optional topic suffix configuration. ## If the section is omitted, no suffix is used. diff --git a/plugins/outputs/kafka/kafka.go b/plugins/outputs/kafka/kafka.go index d61aaadd8..a45e2a4e9 100644 --- a/plugins/outputs/kafka/kafka.go +++ b/plugins/outputs/kafka/kafka.go @@ -70,7 +70,7 @@ var sampleConfig = ` brokers = ["localhost:9092"] ## Kafka topic for producer messages topic = "telegraf" - + ## Optional Client id # client_id = "Telegraf"