Apache NiFi是一个易于使用，功能强大且可靠的分布式系统，用于转换和分发数据。
Kafka Broker + Zookeeper + NiFi KafkaConsumer + Java Producer - SASL_PLAINTEXT 和 PLAIN 选项
对于通过 Kafka 模拟生产和消费消息的项目，我正在尝试设置一个本地环境，使用 SpringBoot Java 作为生产者 -> apache kafka 2.13 作为代理 -> NiFi 1.22 (
当对象之间的JSON数据结构不同时，如何使用Jolt获取属性
有谁在这种情况下如何编写 JOLT 变换： 输入： [ { “id”：“65cf06b62fadc0122dc30f29”， “代码”：“H34.23.9-240216-0003”， ”
如何将json文件中的字段值放入属性nifi中 json文件： { “_id”：“eCT9agQkchqPnyDgd” } 我使用 updateAttribute 不起作用：$._id，{$._id}
一个输出流文件有23行数据，流文件中的每一行都有一个键和值。队列中有很多相似的流程文件，如果其中任何一个流程文件不具备所有所需的 ro...
docker中的Apache nifi：无法访问nifi UI
我为 apache nifi 1.22.0 创建一个 docker 映像，在 dockerfile 中公开端口： 曝光 8080 8443 10000 8000 然后我启动一个 docker 容器： docker run -it --cpus=4 --user root --memory=10g --publish
无法按预期填充字段 在 jolt 变换中，如 if-else 和 if-else（嵌套）？
JSON 输入： { “代码”：“+91-”， “状态”：“A”， “号码”：“123456778”， “国家”：“我”， “pukcode”：&...
Apache NIFI - PutElasticsearchHttp - 错误 400
我正在开发一个从 Syslog 获取数据并将其发送到 Elasticsearch 的流程。 我的流程在端口 1514 上使用“ListenSyslog”（当设置为 514 时，处理器给出错误“端口
我正在尝试创建一个新的 Nifi 定制处理器。 我正在遵循 4 个不同教程中给出的说明。 我只创建处理器的结构，我什至不尝试修改 代码和...
我有一个嵌套的 JSON，如下所示。对象中的键和值需要分成 2 组数组，如预期输出中所示。 输入： { “多发性硬化症”： [ { ...
从数组中提取product.code到Apache NiFi中的新数组
晚安！ 我有一个包含这些数组项的 json： { “项目”： [ { “组织”：“900”， “标识符”：68693000000025， “位置我...
如何在 NiFi 1.23 中仅释放 GetFile 处理器队列中的下一个 csv 文件，直到下游最后一个处理器完成
我开发了一个数据摄取流程，使用 NiFi 1.23.2 处理格式相同的 csv 文件。问题是我只想发布
这是我的输入，我们将基于一个文件名路径进行分组，并将这些相应的文件添加到每个组的单个数组中。 [{ “文件名”：“FF/raw/first/raw_A/
在 NIFI 中使用 JOLT 将 JSON 对象分配为字段值
我有一个存储 JSON 对象的属性“TEST”，我尝试了这个 JOLT，但我得到“无法将 json 编组到对象” 测试： [ { “ORDER_DATE”：“20...
我一直在写一个 json 转换的 jolt，现在已经完成一半了。如果数组中存在，则需要修改数组中的 json 对象，如果根本不存在，则需要创建新对象。
使用HandlehttpRequest初始化服务器失败，绑定失败
`2024-02-12 05:43:26,355 INFO [定时器驱动进程线程 4] org.eclipse.jetty.server.Server jetty-12.0.5;建成：2023-12-18T14:06:32.502Z； git: 3aed62e4959bb8c01f5975fe81e078e3ff626126; jvm 21.0....
使用 ScriptTransformRecord 将时间戳值更改为日期
你好，我正在尝试使用 apache nifi 中的 python y ScriptTransformRecord 进程将 json 中的数据从时间戳转换为日期，我该怎么做？ { “印象_历史_帖子_看过”...
使用 JOLTTRANSFORMJSON APACHE NIFI 将属性添加到我的 JSON 文件
我正在尝试使用apache nifi来练习转换数据，我一直在尝试使用GetFile来获取我的4个JSON文件，我的目标是转换这4合1，但对我来说很重要的是要记住...
我有两个具有相同文件名的流程文件（比如说sample.txt）。现在我需要将这两个流文件合并为一个流文件，但是我需要第一个流的数据，然后我必须应用...
Nifi 流已停止工作。今天，在启动流程时，所有处理器图标都变成绿色，但没有输入或输出，因为GenerateFlowFile 显示活动线程和终止线程。这...
无法使用 localhost:8080/nifi 连接到 Nifi
抱歉，关于这个问题有一些问题，但答案对我没有帮助。我有： 启用 ufw 允许从任何地方连接到 8080 的规则 启用 SSH nifi的状态：正在运行、正在监听...