logstash kafka輸出（發送json數據）

Question

在logstash中，我試圖將數據發送到kafka以及ES。在ES中，數據以與rubydebug所示相同的格式發送（在應用過濾器和添加新字段後基本上是json數據）。我想發送相同的數據給卡夫卡。但是logstash只發送原始消息給kafka。 （我不會修改原始信息）。

是否可以發送相同的數據到我們發送給ES的kafka（json格式）？

Answer 1

設置codec => "json"您的kafka {}輸出可能會給你你要找的。默認是'普通'，它不做任何格式。