1
У меня есть требование прочитать огромный файл CSV из темы Кафка в Кассандру. Я сконфигурировал Apache Nifi для достижения того же.Вставка из Кафки в Кассандру с использованием NIFI
Flow:
Пользователь не имеет контроля над установкой Nifi. Он указывает только URL, где находится CSV. Веб-приложение записывает URL-адрес в тему кафки. Nifi извлекает файл и вставляет его в Cassandra.
Как я узнаю, что Nifi вставил все строки из файла CSV в Cassandra? Мне нужно сообщить пользователю, что вставка выполнена.
Любая помощь будет оценена по достоинству.