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

closes #1113
This commit is contained in:
Cameron Sparr
2016-04-29 18:48:07 -06:00
parent 91460436cf
commit a30b1a394f
2 changed files with 5 additions and 1 deletions

View File

@@ -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,
}
})
}