问题描述
限时送ChatGPT账号..我在谷歌上搜索并阅读 Kafka 文档,但我找不到消费者偏移量的最大值以及最大值后是否有偏移量环绕.我知道偏移量是一个 Int64 值,所以最大值是 0xFFFFFFFFFFFFFFFF.如果有环绕,Kafka 如何处理这种情况?
I was googling and reading Kafka documentation but I couldn't find out the max value of a consumer offset and whether there is offset wraparound after max value. I understand offset is an Int64 value so max value is 0xFFFFFFFFFFFFFFFF. If there is wraparound, how does Kafka handle this situation?
推荐答案
根据这个 post,偏移量未重置:
According to this post, the offset is not reset:
我们目前不回滚偏移量.由于偏移量很长,它可以持续很长时间.一天写1TB就可以继续大约 400 万天.
We don't roll back offset at this moment. Since the offset is a long, it can last for a really long time. If you write 1TB a day, you can keep going for about 4 million days.
此外,您始终可以使用更多分区(每个分区都有自己的偏移量).
Plus, you can always use more partitions (each partition has its own offset).
正如卢西亚诺所说,可能不值得担心.
So as Luciano said, probably not worth worrying about.
这篇关于Kafka消费者偏移最大值?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
更多推荐
[db:关键词]
发布评论