gpt4 book ai didi

java - KafkaConsumer.commitAsync() 行为具有比以前更低的偏移量

转载 作者:行者123 更新时间:2023-12-05 01:34:23 26 4
gpt4 key购买 nike

kafka将如何处理对

的调用

KafkaConsumer.commitAsync(Map<TopicPartition, OffsetAndMetadata> offsets, OffsetCommitCallback callback)

当主题的偏移值被指定为小于先前调用的值时?

最佳答案

它只会将分区的偏移量设置为您指定的值,因此下次您将使用来自 commitedOffset+1 的消息。
commitAsync() 的 javadoc 说:

The committed offset should be the next message your application will consume,i.e. lastProcessedMessageOffset + 1.

关于java - KafkaConsumer.commitAsync() 行为具有比以前更低的偏移量,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/63740084/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com