Add output kafka Idempotent

Elastic Stack Beats
1

I need output to kafka for at most once . Can I create a pull request to beats output kafka as follow:

	if config.Idempotent {
		k.Producer.Idempotent = config.Idempotent
		k.Net.MaxOpenRequests = 1
		k.Producer.RequiredAcks = sarama.WaitForAll
	}
2

Hi @Icedroid !

We already have a Kafka output -> Configure the Kafka output | Filebeat Reference [7.x] | Elastic If this is not enough for you you can always open a Github issue or Pull Request with your addition.

3

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.