我在谷歌上搜索和阅读Kafka文档,但我找不到消费者偏移的最大值以及最大值后是否有偏移环绕.我理解offset是一个Int64值,所以最大值是0xFFFFFFFFFFFFFFFF.如果有回旋,卡夫卡如何处理这种情况？
根据这篇文章,偏移量不会重置:
我们现在不会回滚偏移.由于偏移很长,它可以持续很长时间.如果你每天写1TB,你可以坚持约400万天.
此外,您始终可以使用更多分区(每个分区都有自己的偏移量).
正如卢西亚诺所说,可能不值得担心.
京公网安备 11010802040832号 | 京ICP备19059560号-6 