logstash kafka output 日志處理

今天在用logstash解析日志並傳送給kafka的時候，發現kafka能收到數據但數據內容已經丟失，具體如下：

在logstash output中增加輸出樣式之后，問題解決kafka再次接受到的內容如下圖所示：

output{
kafka{
topic_id => "log_test"
# kafka的地址
bootstrap_servers => "10.10.10.10:9092"
# 一定要注明輸出格式
codec => "json"
}
}