Logstash + 踩踏 + ActiveMQ

Question

我正在使用 logstash 读取 CSV 文件，并post使用 stomp 协议将信息发送到我的 ActiveMQ。

一切都很好，我只想为这些消息添加持久性，但我不知道如何告诉 logstash 这样做。

ActiveMQ 站点说我需要告诉我的 stomp 生产者添加 "persistent:true" 参数，但我在 logstash 站点上找不到任何关于此的文档。

有人知道这件事吗？

提前致谢，

Answer 1

嗯，无法在 logstash stomp 输出上设置持久性。

如果这对您很重要，它应该是源代码中的一个简单修复。

您可以找到文件 here:

还有这一行：

@client.send(event.sprintf(@destination), event.to_json)

应该是这样的：

@client.send(event.sprintf(@destination), event.to_json, :persistent => true)

您必须自己构建并安装插件。我的 Ruby 技能有限，所以我不知道该怎么做。也许考虑将其添加为配置参数并通过拉取请求贡献它？

Answer 2

现在您可以使用属性 headers 发送持久消息：

stomp {
  host => "localhost"
  port => 61612
  destination => "my_queue"
  headers => {
    "persistent" => true
  }
}

Logstash + stomp + ActiveMQ