elasticsearch - Filebeat > Logstash > ElasticSearch - Lumberjack 错误

标签 elasticsearch logstash filebeat

尝试让 Filebeat 与 logstash 一起工作。目前我收到此错误:

2016/11/14 04:54:27.721478 output.go:109: DBG  output worker: publish 2047 events
2016/11/14 04:54:27.756650 sync.go:85: ERR Failed to publish events caused by: lumberjack protocol error
2016/11/14 04:54:27.756676 single.go:91: INFO Error publishing events (retrying): lumberjack protocol error
2016/11/14 04:54:28.782729 sync.go:85: ERR Failed to publish events caused by: lumberjack protocol error
2016/11/14 04:54:28.782756 single.go:91: INFO Error publishing events (retrying): lumberjack protocol error
2016/11/14 04:54:30.786983 sync.go:85: ERR Failed to publish events caused by: lumberjack protocol error
2016/11/14 04:54:30.787017 single.go:91: INFO Error publishing events (retrying): lumberjack protocol error
2016/11/14 04:54:34.808528 sync.go:85: ERR Failed to publish events caused by: lumberjack protocol error
2016/11/14 04:54:34.808578 single.go:91: INFO Error publishing events (retrying): lumberjack protocol error

有没有人有解决方案,或者您可以指出正确的方向?

Filebeat v5 和 logstash v5。

在本地执行此操作。

谢谢!

最佳答案

这可能是因为您的 logstash 对您的 filebeat 不可见。 请在节拍上启动您的 logstash 作为输入。我已经在端口号 31311 上启动了我的 logstash。

    input {
  beats {
    host => "0.0.0.0"
    port => 31311
  }
}

filebeat.yml 中的配置:ElasticSearch 默认输出。请评论它并取消评论 logstash 输出配置。它应该如下所示。

output.logstash:
  # The Logstash hosts
  hosts: ["localhost:31311"]

如果您在这两者之间设置了任何身份验证,请小心。 完成此配置后,我能够在 logstash 中看到我的消息,最后在 Kibana 中看到我的消息。希望它能奏效。

关于elasticsearch - Filebeat > Logstash > ElasticSearch - Lumberjack 错误,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40582638/

相关文章:

elasticsearch - 将城市名称从Logstash映射到GeoPoint到Elasticsearch

json - 在 Logstash 中使用可变键名访问嵌套的 JSON 值

elasticsearch - Filebeat 到 logstash 的连接被拒绝

regex - Grok/Oniguruma 模式匹配来自 X-Forwarded-For header 的第一个 IP

elasticsearch - Filebeat Kubernetes 处理器和过滤

elasticsearch - Elasticsearch `scan`和 `scroll`之后的文档计数不正确,然后 `refresh`和 `flush`

elasticsearch - 如何检查数字范围以及Elasticsearch中的字符串值?

java - Filebeat 与直接从应用程序将日志推送到 Logstash

json - 如何过滤嵌套聚合

search - ElasticSearch 默认评分机制