带有activeMQ/stomp的logstash [英] logstash with activeMQ/stomp

问题描述

全部.

我正在使用logstash-1.4.2来消耗存储在我的activeMQ(带有stomp plubgin)中的消息.

I am using logstash-1.4.2 to consume messages stored in my activeMQ(with stomp plubgin).

在我的acitveMQ.xml配置文件中，有以下一行:

in my acitveMQ.xml config file, I have the line:

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

运行logstash时，出现此错误:

when I run my logstash, I have this error:

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: [e-mail]                |
| * 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中，我有:

in my logstashconfig.conf, I have :

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

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

如果我从RabbitMQ使用以下logstashconfig.conf，它将是正确的(这是我的RabbitMQ版本的config):

If I consume from rabbitMQ, with the following logstashconfig.conf, it would be correct (here is my rabbitMQ version of config):

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"
  }
}

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

I don't have trouble with my rabbitMQ version of logstash, the text file created looks correct.

我的问题是:

1，我的脚踏输入配置错误吗?由于我的配置中没有队列"名称，可能是错误的吗? 2，或者问题是我没有正确创建stomp插件，如果是原因，那将与logstash无关.

1, do I configure my stomp input wrong? since I don't have the "queue" name in my config, it might be wrong? 2, or if the problem is I didn't create the stomp plugin correctly, if that is the reason, it would not be about logstash...

谢谢

推荐答案

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

You need to install the Contributed Plugins. These have been removed from the core download for Logstash. The Stomp plugin is located in the contributed plugins:

踩踏

里程碑:2

这是一个社区贡献的插件！它不附带logstash 默认情况下，但易于安装！要使用此功能，您必须具有 安装了contrib插件包.

This is a community-contributed plugin! It does not ship with logstash by default, but it is easy to install! To use this, you must have installed the contrib plugins package.

此处的路线

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

托管在GitHub此处:

Hosted on GitHub here:

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

这篇关于带有activeMQ/stomp的logstash的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！