NiFi：从 Kafka 主题消费而不移动偏移量

Question

我想知道 Apache Nifi 中是否存在一个处理器，它可以从 Apache Kafka 主题中窥视 "current"（即偏移量现在所在的位置）事件，但不会将偏移量移动到 Kafka 中的下一个事件。

Answer 1

目前没有处理器执行此操作。消费处理器将数据写入NiFi的存储库并提交该操作，然后将偏移量提交给Kafka，以保证NiFi在提交偏移量之前拥有数据。