Nifi ConsumeKafka 获取/轮询查询

Question

我有一个对指定主题进行轮询的 ConsumeKafka 处理器，

这个想法是从 kafka 主题中提取并将其推送到 InfluxDB。

我的 kafka 主题保留期是 2 周。我已将我的 ConsumeKafka 设置为在 latest 偏移处获取。

但是，有时我会停止我的 ConsumeKafka 处理器，那么在这种情况下，处理器是否知道在停止之前获取的记录的最后状态？

停止后播放会发生什么？在停止的时间范围内出现的记录会被忽略吗？

由于我是 Kafka 的新手，请提供一些指导。

Answer 1

您指的是重置偏移量。这意味着，如果您的消费者组被重置或之前不存在，它将重置为最新的偏移量。由于您在停止处理器后没有重置您的消费者组，因此它将从它拉出的最新偏移量继续，而不是直到该点为止的最新偏移量。