# Using Logstash to index MQTT from Mosquitto

**URL:** <https://discuss.elastic.co/t/using-logstash-to-index-mqtt-from-mosquitto/161181>\
**Category:** Logstash\
**Created:** [December 17, 2018, 2:50pm UTC](https://discuss.elastic.co/t/using-logstash-to-index-mqtt-from-mosquitto/161181 "2018-12-17T14:50:44Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![stornian](https://avatars.discourse-cdn.com/v4/letter/s/9de053/32.png) [@stornian](https://discuss.elastic.co/u/stornian)\
**Post date:** [December 17, 2018, 2:50pm UTC](https://discuss.elastic.co/t/using-logstash-to-index-mqtt-from-mosquitto/161181/1 "2018-12-17T14:50:45Z")

</div>

Hello, this is my first time to use MQTT. My goal is to use the mqtt input plugin ([https://github.com/jurek7/logstash-input-mqtt](https://github.com/jurek7/logstash-input-mqtt))

My logstash configuration is:  
 ![Unbenannt](https://us1.discourse-cdn.com/elastic/original/3X/6/8/6869a77d897a9e2249ae851de3f278dda94dabb1.png)

I installed Mosquitto and run it with default settings.

When starting logstash, an error occurs and since I have no prior experience with this topic I have a hard time understanding what it means:

```
[2018-12-17T14:01:36,444][FATAL][logstash.runner]

An unexpected error occurred!

{:error=>PahoMqtt::WritingException, 

:backtrace=>["/home/anstornig/logstash-6.5.1/vendor/bundle/jruby/2.3.0/gems/paho-mqtt-1.0.12/lib/paho_mqtt/sender.rb:41:in `send_packet'",
"/home/anstornig/logstash-6.5.1/vendor/bundle/jruby/2.3.0/gems/paho-mqtt-1.0.12/lib/paho_mqtt/sender.rb:118:in `block in check_ack_alive'",
"org/jruby/RubyArray.java:1734:in `each'", "/home/anstornig/logstash-6.5.1/vendor/bundle/jruby/2.3.0/gems/paho-mqtt-1.0.12/lib/paho_mqtt/sender.rb:114:in `block in check_ack_alive'",
"org/jruby/ext/thread/Mutex.java:148:in `synchronize'", "/home/anstornig/logstash-6.5.1/vendor/bundle/jruby/2.3.0/gems/paho-mqtt-1.0.12/lib/paho_mqtt/sender.rb:112:in `check_ack_alive'",
"/home/anstornig/logstash-6.5.1/vendor/bundle/jruby/2.3.0/gems/paho-mqtt-1.0.12/lib/paho_mqtt/subscriber.rb:142:in `check_waiting_subscriber'",
"/home/anstornig/logstash-6.5.1/vendor/bundle/jruby/2.3.0/gems/paho-mqtt-1.0.12/lib/paho_mqtt/client.rb:194:in `loop_misc'",
"/home/anstornig/logstash-6.5.1/vendor/bundle/jruby/2.3.0/gems/paho-mqtt-1.0.12/lib/paho_mqtt/client.rb:186:in `mqtt_loop'",
"/home/anstornig/logstash-6.5.1/vendor/bundle/jruby/2.3.0/gems/paho-mqtt-1.0.12/lib/paho_mqtt/client.rb:134:in `block in daemon_mode'"]}

[2018-12-17T14:01:36,702][ERROR][org.logstash.Logstash] java.lang.IllegalStateException: Logstash stopped processing because of an error: (SystemExit) exit
```

---

<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:** [January 14, 2019, 2:50pm UTC](https://discuss.elastic.co/t/using-logstash-to-index-mqtt-from-mosquitto/161181/2 "2019-01-14T14:50:49Z")

</div>

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