流利的插件Kafka json转义

Question

我使用的是版本fluent-plugin-kafka版本 0.12.3。

我有一个以 JSON 格式输出其日志的应用程序，但我的控制台使用者显示日志已转义。

例如，应用程序输出以下日志行：

{
"msg": "ok"
}

当我使用控制台使用者查看日志时，它会输出：

{
"container_id": "7e...",
"container_name": "/app",
"source": "stdout",
"log": "{"msg": "ok"}"
}

应如何配置fluent-plugin-kafka以便应用程序日志将嵌套为 JSON 而不对其进行转义？

期望的输出：

{
"container_id": "7e...",
"container_name": "/app",
"source": "stdout",
"log": {
"msg": "ok"
}
}

Answer 1

使用记录转换器滤波器，我能够改变传入的数据。