# Logstash kafka plugin

**URL:** <https://discuss.elastic.co/t/logstash-kafka-plugin/164814>\
**Category:** Logstash\
**Created:** [January 18, 2019, 2:54pm UTC](https://discuss.elastic.co/t/logstash-kafka-plugin/164814 "2019-01-18T14:54:27Z")\
**Posts on this page:** 5\
**Page:** 1

<div class="post-metadata">

**Author:** ![AMITH1284](https://avatars.discourse-cdn.com/v4/letter/a/4491bb/32.png) [@AMITH1284](https://discuss.elastic.co/u/AMITH1284)\
**Post date:** [January 18, 2019, 2:54pm UTC](https://discuss.elastic.co/t/logstash-kafka-plugin/164814/1 "2019-01-18T14:54:27Z")

</div>

When sending logs from kafka to ES, if ES is down and logstash fails to send to ES, will it continue to consume messages from kafka or does it stop consuming as it fails to send?

Thanks

---

<div class="post-metadata">

**Author:** ![Badger](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/badger/32/25190_2.png) [@Badger](https://discuss.elastic.co/u/Badger)\
**Post date:** [January 18, 2019, 3:04pm UTC](https://discuss.elastic.co/t/logstash-kafka-plugin/164814/2 "2019-01-18T15:04:50Z")

</div>

logstash has internal queues. Once they are full it will stop consuming.

---

<div class="post-metadata">

**Author:** ![AMITH1284](https://avatars.discourse-cdn.com/v4/letter/a/4491bb/32.png) [@AMITH1284](https://discuss.elastic.co/u/AMITH1284)\
**Post date:** [January 18, 2019, 3:18pm UTC](https://discuss.elastic.co/t/logstash-kafka-plugin/164814/3 "2019-01-18T15:18:09Z")

</div>

i am sorry. i did not understand it . i am using kafka input plugin to read from kafka and sending to ES. When what is full it will stop consuming?

Thanks

---

<div class="post-metadata">

**Author:** ![Badger](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/badger/32/25190_2.png) [@Badger](https://discuss.elastic.co/u/Badger)\
**Post date:** [January 18, 2019, 3:21pm UTC](https://discuss.elastic.co/t/logstash-kafka-plugin/164814/4 "2019-01-18T15:21:53Z")

</div>

When the internal queue in logstash is full it will stop reading from kafka.

---

<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:** [February 15, 2019, 3:21pm UTC](https://discuss.elastic.co/t/logstash-kafka-plugin/164814/5 "2019-02-15T15:21:56Z")

</div>

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