Godeps update

closes #2356
2017-02-01 16:18:39 +00:00
parent c158346642
commit 7bd6dc3d7f
5 changed files with 62 additions and 58 deletions
--- a/plugins/outputs/kafka/kafka.go
+++ b/plugins/outputs/kafka/kafka.go
@@ -109,6 +109,7 @@ func (k *Kafka) Connect() error {
 	config.Producer.RequiredAcks = sarama.RequiredAcks(k.RequiredAcks)
 	config.Producer.Compression = sarama.CompressionCodec(k.CompressionCodec)
 	config.Producer.Retry.Max = k.MaxRetry
+	config.Producer.Return.Successes = true

 	// Legacy support ssl config
 	if k.Certificate != "" {