# Feature Request - MQTT plugin for ES8266

**URL:** <https://discuss.elastic.co/t/feature-request-mqtt-plugin-for-es8266/51207>\
**Category:** Logstash\
**Created:** [May 28, 2016, 3:22am UTC](https://discuss.elastic.co/t/feature-request-mqtt-plugin-for-es8266/51207 "2016-05-28T03:22:07Z")\
**Posts on this page:** 5\
**Page:** 1

<div class="post-metadata">

**Author:** ![spuder](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/spuder/32/44895_2.png) [@spuder](https://discuss.elastic.co/u/spuder)\
**Post date:** [May 28, 2016, 3:22am UTC](https://discuss.elastic.co/t/feature-request-mqtt-plugin-for-es8266/51207/1 "2016-05-28T03:22:07Z")

</div>

MQTT is becoming a popular message buss for IOT devices like arduinos, raspberry Pi's and ES8266.

It would be great if logstash had an input and an output pluging for MQTT message busses.

Example use case:

> **[MQTT Sensor](https://home-assistant.io/components/sensor.mqtt/)**
>
> Instructions how to integrate MQTT sensors within Home Assistant.

Java library

[http://mqtt.org/tag/java](http://mqtt.org/tag/java)

Ruby library

> **[njh/ruby-mqtt](https://github.com/njh/ruby-mqtt)**
>
> ruby-mqtt - Pure Ruby gem that implements the MQTT protocol, a lightweight protocol for publish/subscribe messaging.

---

<div class="post-metadata">

**Author:** ![warkolm](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/warkolm/32/39224_2.png) [@warkolm](https://discuss.elastic.co/u/warkolm)\
**Post date:** [May 28, 2016, 4:50am UTC](https://discuss.elastic.co/t/feature-request-mqtt-plugin-for-es8266/51207/2 "2016-05-28T04:50:44Z")

</div>

PR's welcome 😉

---

<div class="post-metadata">

**Author:** ![magnusbaeck](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/magnusbaeck/32/44943_2.png) [@magnusbaeck](https://discuss.elastic.co/u/magnusbaeck)\
**Post date:** [May 29, 2016, 11:55am UTC](https://discuss.elastic.co/t/feature-request-mqtt-plugin-for-es8266/51207/3 "2016-05-29T11:55:11Z")

</div>

Have you looked at the existing MQTT plugins?

> **[widarlein/logstash-input-mqtt](https://github.com/widarlein/logstash-input-mqtt)**
>
> Contribute to logstash-input-mqtt development by creating an account on GitHub.

  
[https://github.com/kompa3/logstash-output-mqtt](https://github.com/kompa3/logstash-output-mqtt) (discussion at [https://github.com/elastic/logstash/issues/4487](https://github.com/elastic/logstash/issues/4487))

---

<div class="post-metadata">

**Author:** ![spuder](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/spuder/32/44895_2.png) [@spuder](https://discuss.elastic.co/u/spuder)\
**Post date:** [May 30, 2016, 12:04am UTC](https://discuss.elastic.co/t/feature-request-mqtt-plugin-for-es8266/51207/4 "2016-05-30T00:04:15Z")

</div>

Wow, thanks for finding those. Indeed that is exactly what I'm looking for.

---

<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:** [July 6, 2017, 4:55am UTC](https://discuss.elastic.co/t/feature-request-mqtt-plugin-for-es8266/51207/5 "2017-07-06T04:55:37Z")

</div>