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