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

我们这边用logstash从kafka消费json格式的日志，规则如下：

filter {

    json {

        source => "message" # 解析成json

    }

    mutate {

        remove_field => "message" # 删除原始日志

    }

}

目的是消费出来后，删除kakfa原始日志，也就是message这个字段。但是如果有用户json里面也用了message字段，那这个动作就会将用户的日志字段也一起删除了。。。
 
请问大拿们对于这个问题有没有什么判断、规避方法？