беглый плагин кафка json убегающий - PullRequest
0 голосов
/ 13 февраля 2020

Я использую версию fluent-plugin-kafka версию 0.12.3 .

У меня есть приложение, которое выводит свои журналы в формате JSON, но мой потребитель консоли показывает, что журналы ESCAPED.

Например, приложение выводит следующую строку журнала:

{
  "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"
  }
}

1 Ответ

1 голос
/ 17 февраля 2020

с использованием фильтра записи преобразователя Мне удалось изменить входящие данные.

...