小编Vas*_*ian的帖子

NiFi中漏斗的目的

NiFi UI - 截图

在图像中,有 3 个GenerateFlowFile处理器连接到一个LogAttribute处理器。我想知道漏斗的必要性。请说清楚。

我了解漏斗的一种此类用途,它可用于合并来自此youtube视频中所述的两个不同进程组的组件。

apache-nifi

6
推荐指数
1
解决办法
4184
查看次数

如何识别 GitHub 中使用的是哪个 Git 版本?

我们使用 GitHub 作为企业版本控制系统 - “github.org.com”(我的组织服务器 URL)。

如何查找 GitHub 正在使用的 Git 版本以及 GitHub 版本?

git github

5
推荐指数
1
解决办法
1384
查看次数

在将流文件移动到 NiFi 中的下一个处理器之前引入时间延迟

在 NiFi 中,存在从MQTT(ConsumeMQTT)消费并发布到HDFS路径(PutHDFS)的数据流。我需要在将消耗的数据推送到 HDFS 路径之前引入60 分钟的延迟。发现 ControlRate 和 MergeContent 处理器是可能的解决方案但不确定。

引入时间延迟的理想解决方案是什么?

示例:上午 9:00 使用的流文件应在上午 10:00 发布到 HDFS

在此处输入图片说明

apache-nifi

5
推荐指数
2
解决办法
2302
查看次数

log4j 漏洞 - 如果 log4j 维护在类路径中但未在代码中实际使用,它是否仍然容易受到攻击?

这是针对 log4j-core jar 报告的CVE-2021-44228漏洞,并已在 Log4J v2.15.0 中修复。

我们通过 slf4j 使用 Logback API。这可以通过以下代码确认。

final StaticLoggerBinder binder = StaticLoggerBinder.getSingleton();
System.out.println(binder.getLoggerFactory());
System.out.println(binder.getLoggerFactoryClassStr());
//output:
//ch.qos.logback.classic.LoggerContext[default]
//ch.qos.logback.classic.util.ContextSelectorStaticBinder
Run Code Online (Sandbox Code Playgroud)

mvn dependency:tree在类路径中显示 log4j-core API(版本 <2.15)(直接依赖和传递依赖)。

由于在类路径中维护 log4j-core,应用程序是否仍然容易受到攻击?谢谢你!

java log4j

5
推荐指数
1
解决办法
916
查看次数

查找 NiFi 远程进程组通过其 Rest API 启用或禁用

使用NiFi REST API,

  1. 如何查找远程进程组是启用还是禁用?
  2. NiFi中传输(RemoteProcessGroupDTO)和传输状态(RemoteProcessGroupStatusDTO)之间的区别?

端点:https://nifihost:8080/nifi-api/process-groups/{id}/remote-process-groups

api apache-nifi

1
推荐指数
1
解决办法
360
查看次数

标签 统计

apache-nifi ×3

api ×1

git ×1

github ×1

java ×1

log4j ×1