From 34614582a7820ed59e05b64a7aef7cdfe9eb5e79 Mon Sep 17 00:00:00 2001
From: Daniel Nelson <daniel.nelson@influxdb.com>
Date: Wed, 15 Aug 2018 14:12:22 -0700
Subject: [PATCH] Use snake case in kafka output config

---
 plugins/outputs/kafka/kafka.go | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/plugins/outputs/kafka/kafka.go b/plugins/outputs/kafka/kafka.go
index dc8d846da..0bb5ca4a3 100644
--- a/plugins/outputs/kafka/kafka.go
+++ b/plugins/outputs/kafka/kafka.go
@@ -38,7 +38,7 @@ type (
 		// MaxRetry Tag
 		MaxRetry int
 		// Max Message Bytes
-		MaxMessageBytes int
+		MaxMessageBytes int `toml:"max_message_bytes"`
 
 		Version string `toml:"version"`
 
@@ -142,8 +142,9 @@ var sampleConfig = `
   ## until the next flush.
   # max_retry = 3
 
-  ## Max message bytes, should be lower than server message.max.bytes config
-  # MaxMessageBytes = 0
+  ## The maximum permitted size of a message. Should be set equal to or
+  ## smaller than the broker's 'message.max.bytes'.
+  # max_message_bytes = 1000000
 
   ## Optional TLS Config
   # tls_ca = "/etc/telegraf/ca.pem"