Я работаю с сообщениями опроса потребительской службы каждый интервал от 500 до 10000 записей, в то время как повторение каждые 30 секунд происходит один раз. Я хочу использоватьkaka после завершения всех заданий на следующей итерации. Но процессор consumerkafka не поддерживает восходящее соединение.
после успешного завершения puthdfs мне нужно использовать следующую итерацию здесь, я упомянул рабочий процесс nifi.
Рабочий процесс:
потреблениеkafka -> mergecontent- > convertRecord-> updateattribute-> puthdfs