Using Logstash to index MQTT from Mosquitto


#1

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)

My logstash configuration is:
Unbenannt

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

(system) #2

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