在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”,不进行任何格式化。