Можно ли получить данные от nifi и добавить эти данные к данным, полученным от kafka?

Question

Можно ли получить данные от nifi и добавить эти данные к данным, полученным от kafka?

Я попытался ввести данные и просмотреть данные. Но я не знаю, как получить эти данные. Получаете ли вы сложенные данные в очереди? Импортируете ли вы данные, хранящиеся в определенном каталоге?

Во-первых, мне интересно, возможно ли это в nifi. Как только вы ввели определенные данные, удерживайте их некоторое время. (Например, 'testtext') Когда вы получаете определенные данные от kafka, вы добавляете данные, которые у вас есть некоторое время назад. (Например, если вы получаете данные kafka, результатом должно быть «kafka data testtext».)

Answer 1

Использовать MergeContent процессор.

• Используйте Max Bin Age значение свойства (5 минут и т. Д.) Для принудительного объединения потоковых файлов.

• См. это и это ссылки для настройки / использования процессора слияния.