带有activeMQ/stomp的logstash答案

【问题标题】：logstash with activeMQ/stomp带有activeMQ/stomp的logstash
【发布时间】：2014-07-02 04:40:59
【问题描述】：

全部。

我正在使用 logstash-1.4.2 来使用存储在我的 activeMQ 中的消息（带有 stomp 插件）。

在我的 acitveMQ.xml 配置文件中，我有一行：

<transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>

当我运行我的 logstash 时，我遇到了这个错误：

C:\logstash\logstash-1.4.2\bin>logstash agent -f logstashconfig.conf
+---------------------------------------------------------+
| An unexpected error occurred. This is probably a bug.   |
| You can find help with this problem in a few places:    |
|                                                         |
| * chat: #logstash IRC channel on freenode irc.          |
|     IRC via the web: http://goo.gl/TI4Ro                |
| * email: logstash-users@googlegroups.com                |
| * bug system: https://logstash.jira.com/                |
|                                                         |
+---------------------------------------------------------+
The error reported is:
  Couldn't find any input plugin named 'stomp'. Are you sure this is correct? Trying to load the stomp input plugin resulted in this error: no such file to load -- logstash/inputs/stomp

在我的 logstashconfig.conf 中，我有：

input {
  stomp {  
    password => "admin"
    user => "admin"
  }
}

output {
  file {
    path => "C:\logstash\logstash-1.4.2\cosumedfromstomp.txt"
  }
}

如果我从rabbitMQ消费，使用以下logstashconfig.conf，那将是正确的（这是我的rabbitMQ版本的配置）：

input {
  rabbitmq {
    host => "amqp"
    queue => "elasticsearch"
    key => "elasticsearch"
    exchange => "elasticsearch"
    type => "all"
    durable => true
    auto_delete => false
    exclusive => false
    format => "json_event"
    debug => false
  }
}

output {
  file {
    path => "C:\logstash\logstash-1.4.2\cosumedfromstomp.txt"
  }
}

我的 rabbitMQ 版本的 logstash 没有问题，创建的文本文件看起来是正确的。

我的问题是：

1，我是否配置了我的单脚输入错误？因为我的配置中没有“队列”名称，所以可能是错误的？ 2，或者如果问题是我没有正确创建stomp插件，如果是这个原因，那就不是logstash...

谢谢

【问题讨论】：

标签： activemq logstash

【解决方案1】：

您需要安装贡献插件。这些已从 Logstash 的核心下载中删除。 Stomp 插件位于贡献的插件中：

跺脚

里程碑：2

这是一个社区贡献的插件！它不附带logstash 默认情况下，但它很容易安装！要使用它，您必须拥有安装了 contrib 插件包。

这里的路线：

http://logstash.net/docs/1.4.2/contrib-plugins

在 GitHub 上托管：

https://github.com/elasticsearch/logstash-contrib

【讨论】：