logstash kafka 输出（发送 json 数据）

Question

在logstash 中，我正在尝试将数据发送到kafka 和ES。在 ES 中，数据以与 ruby​​debug 所示相同的格式发送（基本上是应用过滤器和添加新字段后的 json 数据）。我想将相同的数据发送到kafka。但是logstash只将原始消息发送给kafka。 （我没有修改原始消息）。

是否可以将相同的数据发送到我们发送给 ES 的 kafka（json 格式）？

Answer 1

在您的kafka {} 输出上设置codec => "json" 可能会给您所需的内容。默认为“plain”，不进行任何格式化。