# Logstash Crash with Persistent Queue and Kafka Input

**URL:** <https://discuss.elastic.co/t/logstash-crash-with-persistent-queue-and-kafka-input/90479>\
**Category:** Logstash\
**Created:** [June 22, 2017, 2:16pm UTC](https://discuss.elastic.co/t/logstash-crash-with-persistent-queue-and-kafka-input/90479 "2017-06-22T14:16:50Z")\
**Posts on this page:** 1\
**Showing post:** 5

<div class="post-metadata">

**Author:** ![guyboertje](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/guyboertje/32/31592_2.png) [@guyboertje](https://discuss.elastic.co/u/guyboertje)\
**Post date:** [July 3, 2017, 8:19am UTC](https://discuss.elastic.co/t/logstash-crash-with-persistent-queue-and-kafka-input/90479/5 "2017-07-03T08:19:50Z")

</div>

Apologies that we missed this question.

How are you getting you beats data into Kafka? Direct or via LS.  
1)

```auto
Beats -> LS -> Kafka -> LS(PQ) -> ES

```

or 2)

```auto
Beats -> Kafka -> LS(PQ) -> ES

```

**Also, which beats are you using?**

See [this comment for an explanation of the problem](https://discuss.elastic.co/t/logstash-5-4-repeated-deserialization-errors-and-losing-data-with-persistent-queues/91503/5?u=guyboertje)

---

_[View the full topic](https://discuss.elastic.co/t/logstash-crash-with-persistent-queue-and-kafka-input/90479)._