Q:非洲食人族的酋长吃什么?

请教logstash处理从kafka消费的json日志的message字段处理问题

Logstash | 作者 Jager918 | 发布于2020年08月28日 | 阅读数:2482

我们这边用logstash从kafka消费json格式的日志,规则如下:
filter {
json {
source => "message" # 解析成json
}
mutate {
remove_field => "message" # 删除原始日志
}
}
目的是消费出来后,删除kakfa原始日志,也就是message这个字段。但是如果有用户json里面也用了message字段,那这个动作就会将用户的日志字段也一起删除了。。。
 
请问大拿们对于这个问题有没有什么判断、规避方法?
已邀请:

要回复问题请先登录注册