Kafka主题分区中可以存储的最大消息数?

Hem*_*lla 3 apache-kafka

我已将保留政策设置为48小时。因此,最终将清除旧日志。但是话题的抵消量一直在增长。该号码何时重置?达到最大偏移量会怎样?在创建新段时,新段也将以基本偏移量作为fliename滚动。达到此限制时,.log和.index文件的文件名是什么?

以下是日志段的当前基本偏移量: 日志段的当前基本偏移量

Han*_*sen 6

偏移量永远不会重置,因为最大偏移量值太大(int64),您将永远无法达到它。

  • 仅有292年的时间,如果您每纳秒创建一条消息,它就会翻转。:-) (3认同)