流利的插件kafka json转义

Question

我正在使用版本fluent-plugin-kafka version 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

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