input {
stdin {}
}
filter {
json {
source => "message"
}
#根据需求，进行判断
if [kubs]!="" {
mutate {
add_field => { "kubs_json" => "%{kubs}"} #指定要二次解析的json的key，并指定临时变量kubs_json
}
json {
source => "kubs_json" 将变量进行解析。
remove_field =>["kubs_json" ] 删除临时变量
}
}
}
output {
stdout { }
}