Kafka output: set max_retry=3 & required_acks=-1 as defaults

closes #1113
influxdata · Apr 30, 2016 · fda4083 · fda4083
1 parent 9146043
commit fda4083
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/plugins/outputs/kafka/kafka.go b/plugins/outputs/kafka/kafka.go
@@ -181,6 +181,9 @@ func (k *Kafka) Write(metrics []telegraf.Metric) error {
 
 func init() {
 	outputs.Add("kafka", func() telegraf.Output {
-		return &Kafka{}
+		return &Kafka{
+			MaxRetry:     3,
+			RequiredAcks: -1,
+		}
 	})
 }