Как отправить обновленные данные из Java-программы на NiFi? - PullRequest
0 голосов
/ 01 апреля 2019

У меня запущены микро-сервисы, и когда веб-пользователь обновляет данные в БД с использованием конечных точек микро-сервисов, я хочу также отправлять обновленные данные в NiFi.Эти данные содержат обновленный список имен, удаленные имена, отредактированные имена и т. Д. Как это сделать?какой процессор я должен использовать со стороны NiFi?

Я новичок в NiFi.Мне еще предстоит попробовать что-нибудь с моей стороны.Я читаю документы Google, которые могут мне помочь.

Исходный код не написан.Я хочу начать это.Но я поделюсь здесь, как только напишу.

Ожидаемый результат: NiFi должен получить обновленный список имен, а NiFi должен ссылаться на обновленный список для генерации необходимых предупреждений / триггеров и т. Д.

1 Ответ

1 голос
/ 01 апреля 2019

Вы можете сделать это разными способами.MQ, Kafka, HTTP (usinh ListenHTTP ).Просто разверните соответствующий файл и настройте его, даже прослушивайте каталог (используя ListFile & FetchFile ).Вы можете подключить NiFi практически ко всему, поэтому просто выберите способ подключения своих микроуслуг к NiFi.

...