Нифи, обрабатывающая кафку на запрос записи - PullRequest
Новая
       22

Нифи, обрабатывающая кафку на запрос записи

0 голосов
/ 14 января 2020

Прежде всего я оцениваю nifi как kafka stream / topi c validator.

Я обрабатываю kafka topi c так: 

ConsumeKafka -> ConvertRecord(JsonTreeReader, JsonRecordSetWriter) -> QueryRecord -> DebugFlow

Мой образец json is: {"array": [1,2,3], "boolean": true, "country": "XXXX"}

Сконфигурировано QueryRecord.sql: select * from FLOWFILE where country="XXXX" Однако на моем "sql" канале я не получаю результатов, глядя на сбойный канал для отладки. Я вижу, что ConvertRecord изменяет сообщение json от kafka: 

[{"array":[1,2,3],"boolean":true,"country":"XXXX"}]

Итак, я вижу, что есть оберточный массив поверх оригинала json.

Любой совет, как go узнать об этом?

...