我正在尝试使用<code>ConsumeKafkaRecord</code>作为阅读器的<code>JsonTreeReader</code>处理器从Kafka进行读取。

我正在尝试在NiFi（1.11.4）中构建一个流，该流从AMQ读取Avro消息，使用Merge Records处理器对其进行累积，

我有一个定制的nifi处理器，该处理器使用外部数据进行某些用户控制的配置。我想知道如何在更改数据

我正在遵循<a href="https://hub.docker.com/r/apache/nifi" rel="nofollow noreferrer">https://hub.docker.com/r/apache/nifi</a>的“独

我们有一个由3个节点组成的NiFi集群，其中部署了100个流。我们已在NiFi中配置了一个任务ReportLineageToAtlas

我正在运行一个NiFi流，其中我有InvokeHTTP处理器通过flask API调用python脚本。当我处理许多文件（以100个为

我正在尝试使用InvokeHttp将消息推送到我的kafka主题中，但是显示连接错误。

<strong>谁能帮助我正确的Grok模式从nifi的以下示例日志（仅消息部分）中仅检索id值</strong> <ol> <li> o.a

我正在开发使用<code>DBCPService</code>和<code>RecordReader</code>的自定义处理器。 对于Maven项目，我无法添

我有几个Nifi流使用卡夫卡的数据，然后将其写入HDFS。在HDFS上进行写入之前，我们使用<code>MergeContent</cod

使用PUTHDFS处理器将数据加载到HDFS中会有一个延迟。压缩后，虽然大小从MB更改为GB，但要在1小时后加载

我正在创建“ DBCPConnectionPool”类型的控制器服务。但是，该服务不会进入启用状态，而是停留在启用阶

任务-我必须将流从Dev部署到Prod。 挑战-我已经在Dev机器上的参数上下文中设置了敏感值（例如name-d

最近，我将代码从SQL Server移到了ETL工具（我想监视警报）。但是，我在运行时发现了此警报： 我

如果能在这里进行指导，请多谢。 我们的ldap结构如下。 用户1： CN = user1，OU = nonAssociates，OU = users

是否可以通过发送http请求来接收来自kafka的消息？<a href="https://i.stack.imgur.com/x0FYN.png" rel="nofollow noreferrer"

我有一个csv文件，其中的记录是这样的多行 <pre><code>1,2,3,4,5,6,7 1,2,3,4 ,5,6, 7 1,2 3,4 ,5,6, 7 </code></p

我有一个数据源，其中的表用户有<code>name</code>，<code>age</code>和<code>role</code>列。现在，我需要从中创建

如何获取队列大小作为参数？ <a href="https://i.stack.imgur.com/0lU47.png" rel="nofollow noreferrer"><img src="https://i.stack

所以我是NiFi的完整菜鸟，当我第一次尝试时，我只运行了一个“ GetFile”处理器并将其设置为一个相当