Я никогда раньше не использовал Jolt Transform, и я не уверен, как исправить то, что сделал,...
У меня есть специальная служба контроллера, которую я хочу использовать вместе с процессором...
Я могу удаленно отлаживать пользовательский процессор apache nifi в eclipse (ref: 1 , 2 , 3 )
У меня есть два XML-файла (фиктивные версии ниже, фактически содержит PII), которые я пытаюсь...
Я пытаюсь подключиться к hbase, используя следующий код: @ Test public void onTrigger () выдает...
Возможно ли заменить базу данных Apache Nifi H2 на другую БД (например, Postgres или MySql)...
Я могу нормально запустить скрипт, когда я вошел в терминал, но тот же самый скрипт, когда он...
Я пытаюсь использовать UpdateRecord для замены значения вложенного поля. Я почти уверен, что...
Я пытаюсь отфильтровать выбранные поля из процессора Nifi GetMongo, но традиционный подход, похоже,...
На специально разработанном мной процессоре я хочу, чтобы проверка свойств могла сделать некоторые...
Можно ли ссылаться на содержимое FlowFile в последующем ExecuteSQL процессоре? Например: Я...
Я не уверен, что этот вопрос где-то уже адресован, но я не смог найти полезного ответа в Интернете....
Можно ли получить данные от nifi и добавить эти данные к данным, полученным от kafka? Я попытался...
Как вставить постоянный элемент, не требующий ввода json, в массив? Мое намерение Я перехватил...
Я использую Kafka для десериализации сообщений Avro.Для этого программа должна извлечь...
В NiFi у меня есть процессор ExecuteSQL, который возвращает следующее person_id| name | adress 01 |...
Пожалуйста, помогите! Я читаю три типа файлов через ListFtp, например: TRB_TIT_D190125.txt...
Отправьте сообщение kafka через «Процесс публикации kafka» в nifi.Другая Java-программа,...
Я могу переносить таблицы HBase из одного кластера в другой через NiFi.Но это на уровне таблиц, и...
Я недавно установил NiFi, и он работал нормально в течение нескольких дней. Но вдруг сегодня, когда...
Я новичок в NiFi. Я пытаюсь выполнить скрипт Python, используя ExecuteScript процессор. Когда я...
Я пытаюсь генерировать потоки ipfix / netflow с очень высокой скоростью. Для этого я использую...
У меня есть требование, когда мне нужно выполнять 4 задания параллельно, и когда одинаковые задания...
Ввод JSON { "data": [ { "id": "1", "name": "a",...
Мне нужно вставить несколько CSV-файлов, основанных на именах таблиц, в соответствующие таблицы...