dom/telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Add support for static and random routing keys in kafka output (#4579)

Browse Source
This commit is contained in:
Daniel Nelson
2018-08-21 12:44:10 -07:00
committed by GitHub
parent edb6e1f655
commit d2cf9a7157
3 changed files with 102 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
plugins/outputs/kafka/README.md
View File

@@ -50,6 +50,13 @@ This plugin writes to a [Kafka Broker](http://kafka.apache.org/07/quickstart.htm
## ie, if this tag exists, its value will be used as the routing key
routing_tag = "host"
## Static routing key. Used when no routing_tag is set or as a fallback
## when the tag specified in routing tag is not found. If set to "random",
## a random value will be generated for each message.
## ex: routing_key = "random"
## routing_key = "telegraf"
# routing_key = ""
## CompressionCodec represents the various compression codecs recognized by
## Kafka in messages.
## 0 : No compression