Logstash、EC2 和弹性搜索答案

【问题标题】：Logstash, EC2 and elasticsearchLogstash、EC2 和弹性搜索
【发布时间】：2014-03-26 09:29:33
【问题描述】：

我在 EC2 中设置了两个弹性搜索节点，并尝试使用 logstash。运行 logstash 时出现此错误：

log4j, [2014-02-24T10:45:32.722]  WARN: org.elasticsearch.discovery.zen.ping.unicast: [Ishihara, Shirow] failed to send ping to [[#zen_unicast_1#][inet[/10.110.65.91:9300]]]
org.elasticsearch.transport.RemoteTransportException: Failed to deserialize exception response from stream
Caused by: org.elasticsearch.transport.TransportSerializationException: Failed to deserialize exception response from stream
    at org.elasticsearch.transport.netty.MessageChannelHandler.handlerResponseError(MessageChannelHandler.java:169)
    at org.elasticsearch.transport.netty.MessageChannelHandler.messageReceived(MessageChannelHandler.java:123)
    at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)

这是它的一个sn-p。这是我与 logstash 一起使用的 conf 文件：

input {
  redis {
    host => "10.110.65.91"
    # these settings should match the output of the agent
    data_type => "list"
    key => "logstash"

    # We use the 'json' codec here because we expect to read
    # json events from redis.
    codec => json
  }
}

output {
  stdout { debug => true debug_format => "json"}

  elasticsearch {
  host => "10.110.65.91"
  cluster => searchbuild
        }
}
~

我在 .91 上运行 Logstash（打开第二个终端窗口）我错过了什么吗？

【问题讨论】：

两个节点上的 java 版本是否相同？ jontai.me/blog/2013/06/…
是的。我对 Logstash 很陌生。据我了解，我应该有第三台服务器充当“索引器”，另一个是“托运人”，对吗？
我修好了。我不得不将“elasticsearch”更改为“elasticsearch_http”
我也有类似的问题：elasticsearch 的问题已经修复后，logstash 不再自动启动，我创建了一个question，有人可以帮帮我吗？

标签： amazon-web-services amazon-ec2 elasticsearch logstash

【解决方案1】：

我不得不将“elasticsearch”改为“elasticsearch_http”。

固定。

【讨论】：

如果您想不通过 HTTP 请求连接到 elasticsearch，这并不能解决原始问题。