apache-nifi - 在 NiFi 中获取与消费

Question

我看到一些处理器同时具有 GetXXX 和 ConsumeXXX 变体（例如 GetKafka 和 ConsumeKafka）。何时使用 GetXXX 而非 ConsumeXXX 来命名处理器？

注意：我了解ConsumeKafka 和 GetKafka 之间的技术差异。我的问题主要是关于命名约定。

Answer 1

名称背后没有真正的含义，从技术上讲，它们可以被命名为任何东西。典型的约定是以描述正在执行的操作的动词开头处理器名称，然后是正在执行的系统/事物。

“获取”处理器通常是没有传入连接并从某个外部源提取数据的处理器，而“放置”处理器通常是向外部系统传递数据的处理器。

当第一个 Kafka 处理器使用 0.8 Kafka 客户端开发时，它们被称为 GetKafka 和 PutKafka。社区随后也希望同时支持 Kafka 0.9，因此实现了 ConsumeKafka 和 PublishKafka，这更符合 Kafka 的术语，并且还提供了另一个名称，因为它们不能也称为 GetKafka 和 PutKafka。