# Logstash kafka output - producer type for version 2.x

**URL:** <https://discuss.elastic.co/t/logstash-kafka-output-producer-type-for-version-2-x/58236>\
**Category:** Logstash\
**Created:** [August 17, 2016, 9:22am UTC](https://discuss.elastic.co/t/logstash-kafka-output-producer-type-for-version-2-x/58236 "2016-08-17T09:22:55Z")\
**Posts on this page:** 3\
**Page:** 1

<div class="post-metadata">

**Author:** ![ronnysh](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/ronnysh/32/50068_2.png) [@ronnysh](https://discuss.elastic.co/u/ronnysh)\
**Post date:** [August 17, 2016, 9:22am UTC](https://discuss.elastic.co/t/logstash-kafka-output-producer-type-for-version-2-x/58236/1 "2016-08-17T09:22:55Z")

</div>

Hi guys,

we need to configure sync producer type for kafka output plugin (or understand what is the default in version 2.x.)  
there was such variable in version 1.5 but it was removed - [https://www.elastic.co/guide/en/logstash/1.5/plugins-outputs-kafka.html#plugins-outputs-kafka-producer\_type](https://www.elastic.co/guide/en/logstash/1.5/plugins-outputs-kafka.html#plugins-outputs-kafka-producer_type).

anyone has idea how to configure this in version 2.x?

thanks in advance,

Ronnysh

---

<div class="post-metadata">

**Author:** ![Joe\_Lawson](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/joe_lawson/32/3390_2.png) [@Joe\_Lawson](https://discuss.elastic.co/u/Joe_Lawson)\
**Post date:** [August 22, 2016, 3:43pm UTC](https://discuss.elastic.co/t/logstash-kafka-output-producer-type-for-version-2-x/58236/2 "2016-08-22T15:43:44Z")

</div>

The 0.9+ producer has the sync and async all built into one. You want [acks](https://www.elastic.co/guide/en/logstash/current/plugins-outputs-kafka.html#plugins-outputs-kafka-acks) to be 1 or all for a sync operation.

Keep in mind that Kafka has an internal buffer so you have to keep in mind [https://www.elastic.co/guide/en/logstash/current/plugins-outputs-kafka.html#plugins-outputs-kafka-block\_on\_buffer\_full](https://www.elastic.co/guide/en/logstash/current/plugins-outputs-kafka.html#plugins-outputs-kafka-block_on_buffer_full) and [https://www.elastic.co/guide/en/logstash/current/plugins-outputs-kafka.html#plugins-outputs-kafka-buffer\_memory](https://www.elastic.co/guide/en/logstash/current/plugins-outputs-kafka.html#plugins-outputs-kafka-buffer_memory) all come into play.

Really if you need synchronized, known writes, you need to write your own Kafka output that can check the status of the message being submitted as right now Logstash doesn't do stuff like that so there is a small chance of losing some progress in the buffer if stuff crashed.

---

<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:** [July 6, 2017, 4:42am UTC](https://discuss.elastic.co/t/logstash-kafka-output-producer-type-for-version-2-x/58236/3 "2017-07-06T04:42:15Z")

</div>

Closed on July 6, 2017, 4:42am UTC