要将Filebeat的输出格式设置为JSON,您可以在Filebeat配置文件中进行以下更改:
- 打开Filebeat配置文件(通常是
filebeat.yml)。 - 在
output.kafka部分找到或添加以下行:
output.kafka:
codec.format:
string: '{"message": "%{[message]}"}'
- 这将使用JSON格式化将消息包装在一个名为
message的字段中。您还可以根据需要调整JSON格式。
保存并关闭配置文件后,重新启动Filebeat即可生效。现在,Filebeat将以JSON格式发送消息到Kafka主题。
内容由零声教学AI助手提供,问题来源于学员提问




