在Filebeat中,如果你想将消息格式设置为JSON,并且将消息字段放到根目录,你可以使用以下配置:
output.kafka:
hosts: ["kafka-server:9092"]
topic: "your_topic"
codec.format:
string: '{"message": "%{[message]}"}'
这里的codec.format.string指定了消息的格式。%{[message]}是一个占位符,表示将message字段的值作为字符串插入到JSON中的"message"字段中。
注意替换kafka-server:9092为你实际的Kafka服务器地址和端口号,以及将your_topic替换为你要发送消息的Kafka主题名称。
内容由零声教学AI助手提供,问题来源于学员提问




