如何使用 Logstash 和 rabbitmq 输出设置内容类型?

How to set content type with Logstash & rabbitmq output?

我想用 logstash 解析日志并通过 rabbitmq 发送结果。使用这些结果的应用程序正在等待 content_type 设置为 "application/json" 的消息。目前,我的消息没有属性,我的应用程序无法处理该消息。

您能告诉我 logstash 如何将 属性 "content_type" 设置为 "application/json" 的消息发送到 rabbitmq 吗?

在此先致谢并致以最诚挚的问候,

罗曼.

抱歉,目前无法执行此操作。我已经为你归档了github.com/logstash-plugins/logstash-output-rabbitmq bug #6

在该错误得到解决之前,也许您可​​以编写一个简单的微服务来使用无内容类型的消息,并使用正确的内容类型声明将它们重新发布到另一个主题、交换或队列上。

正如@Magnus Bäck 所说,开箱即用是不可能的。但是如果你真的需要它,你可以 fork rabbitmq 插件。并将 :content_type => 'application/json' 之类的内容添加到 this line