rod*_*olk 13 offset apache-kafka kafka-consumer-api
我在谷歌上搜索和阅读Kafka文档,但我找不到消费者偏移的最大值以及最大值后是否有偏移环绕.我理解offset是一个Int64值,所以最大值是0xFFFFFFFFFFFFFFFF.如果有回旋,卡夫卡如何处理这种情况?
Mat*_*lse 28
根据这篇文章,偏移量不会重置:
我们现在不会回滚偏移.由于偏移很长,它可以持续很长时间.如果你每天写1TB,你可以坚持约400万天. 此外,您始终可以使用更多分区(每个分区都有自己的偏移量).
我们现在不会回滚偏移.由于偏移很长,它可以持续很长时间.如果你每天写1TB,你可以坚持约400万天.
此外,您始终可以使用更多分区(每个分区都有自己的偏移量).
正如卢西亚诺所说,可能不值得担心.
归档时间:
10 年 前
查看次数:
6567 次
最近记录: