我在用 GetKafka Apachenifi的阅读信息。当我重新启动处理器时，我希望它总是从最新的偏移量中读取，而不是这个组提交的偏移量。我怎样才能做到呢？
GetKafka
bxgwgixi1#
这个 GetKafka 处理器已弃用。请使用 ConsumeKafka 而不是处理器。这个处理器有一个称为偏移重置的设置，它接受最早、最晚和无作为选项。你需要什么就做什么。注：如果您还需要 GetKafka 要使用kafka 0.8示例，有一个自动偏移重置选项，可以使用最小值和最大值。
ConsumeKafka
1条答案
按热度按时间bxgwgixi1#
这个
GetKafka处理器已弃用。请使用ConsumeKafka而不是处理器。这个处理器有一个称为偏移重置的设置，它接受最早、最晚和无作为选项。你需要什么就做什么。注：如果您还需要
GetKafka要使用kafka 0.8示例，有一个自动偏移重置选项，可以使用最小值和最大值。