在 NiFi 中获取与消费

Question

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

注：我理解technical differences between ConsumeKafka and GetKafka。我的问题主要是关于命名约定。

Answer 1

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

"Get" 处理器通常是没有传入连接并从某些外部源提取数据的处理器，"Put" 处理器通常是将数据传送到外部系统的处理器。

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