流利的插件 kafka json 转义

Question

我有一个以 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

使用 record transformer filter 我能够改变传入的数据。

fluent plugin kafka json escaping