MQTTからのログをfluentdで回収するというネタでfluentd-mqttというのをつくりました。
取り急ぎgithubで公開しています。
以下の制限があります
・MQTT Clientとして動作する
・fluentd v10ではtd-agent.confで"#"をするとコメント扱いになるため、topicの設定ができない。
（DSLを使えばいけます）
・MQTTからpublishされてくる値はJSONであることを期待しています。
取り急ぎ公開しました。
もう少し整備してgemにします。