# Add output kafka Idempotent

**URL:** <https://discuss.elastic.co/t/add-output-kafka-idempotent/283594>\
**Category:** Beats\
**Tags:** filebeat\
**Created:** [September 8, 2021, 1:46am UTC](https://discuss.elastic.co/t/add-output-kafka-idempotent/283594 "2021-09-08T01:46:28Z")\
**Posts on this page:** 3\
**Page:** 1

<div class="post-metadata">

**Author:** ![Icedroid](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/icedroid/32/93608_2.png) [@Icedroid](https://discuss.elastic.co/u/Icedroid)\
**Post date:** [September 8, 2021, 1:46am UTC](https://discuss.elastic.co/t/add-output-kafka-idempotent/283594/1 "2021-09-08T01:46:28Z")

</div>

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

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

```

---

<div class="post-metadata">

**Author:** ![ChrsMark](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/chrsmark/32/55858_2.png) [@ChrsMark](https://discuss.elastic.co/u/ChrsMark)\
**Post date:** [September 8, 2021, 6:30am UTC](https://discuss.elastic.co/t/add-output-kafka-idempotent/283594/2 "2021-09-08T06:30:11Z")

</div>

Hi @Icedroid !

We already have a Kafka output -\> [Configure the Kafka output | Filebeat Reference [7.x] | Elastic](https://www.elastic.co/guide/en/beats/filebeat/7.x/kafka-output.html) If this is not enough for you you can always open a Github issue or Pull Request with your addition.

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [October 6, 2021, 8:31am UTC](https://discuss.elastic.co/t/add-output-kafka-idempotent/283594/3 "2021-10-06T08:31:09Z")

</div>

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