在logstash，我正试图将数据发送给Kafka和es。在es中，数据以rubydebug显示的相同格式发送（基本上是应用过滤器和添加新字段后的json数据）。我想把同样的数据发给Kafka。但是logstash只向Kafka发送原始信息我没有修改原始邮件）。有没有可能将相同的数据发送到kafka（json格式），我们将其发送到es？
wr98u20j1#
设置 codec => "json" 在你的 kafka {} 输出可能会给你你想要的。默认值为“plain”，不进行任何格式化。
codec => "json"
kafka {}
1条答案
按热度按时间wr98u20j1#
设置
codec => "json"在你的kafka {}输出可能会给你你想要的。默认值为“plain”，不进行任何格式化。