# Full pipeline Logstash with dead letter queue

**URL:** https://discuss.elastic.co/t/full-pipeline-logstash-with-dead-letter-queue/239855
**Category:** Logstash
**Created:** [July 3, 2020, 8:39pm UTC](https://discuss.elastic.co/t/full-pipeline-logstash-with-dead-letter-queue/239855 "2020-07-03T20:39:06Z")
**Posts on this page:** 1
**Showing post:** 3

<div class="post-metadata">

### Author: ![Altamir\_Dias](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/altamir_dias/32/69586_2.png) [@Altamir\_Dias](https://discuss.elastic.co/u/Altamir_Dias)
#### Post date: [July 7, 2020, 11:14pm UTC](https://discuss.elastic.co/t/full-pipeline-logstash-with-dead-letter-queue/239855/3 "2020-07-07T23:14:39Z")

</div>

Thank's @Texugo.

Actually, I'm not had undestand Dead Letter Queue yeat. My problem was resolved.  
For this my configuration is similiar with below:

**pipelines.yml**

```
    - pipeline.id: main
      path.config: "/etc/logstash/conf.d/logstash.conf"

    - pipeline.id: deadletter
      path.config: "/etc/logstash/conf.d/logstash_dlq.conf"

```

**logstash.yml**

```
    dead_letter_queue.enable: true

```

**logstash\_dlq.conf** (created by me)  
input{  
dead\_letter\_queue{  
id =\> deadletter  
path =\> "/var/lib/logstash/dead\_letter\_queue"  
commit\_offsets =\> true  
pipeline\_id =\> "main"  
}  
}  
filter {  
mutate {  
add\_field =\> {  
"error\_reason" =\> "%{[@metadata][dead\_letter\_queue][reason]}"  
"plugin\_id" =\> "%{[@metadata][dead\_letter\_queue][plugin\_id]}"  
"plugin\_type" =\> "%{[@metadata][dead\_letter\_queue][plugin\_type]}"  
"entry\_time" =\> "%{[@metadata][dead\_letter\_queue][entry\_time]}"  
}  
}  
}  
output {  
elasticsearch{  
#Elasticsearch Config  
}  
}

---

_[View the full topic](https://discuss.elastic.co/t/full-pipeline-logstash-with-dead-letter-queue/239855)._