切分文件
●大小分片 当前日志分段文件的大小超过了 broker 端参数 log.segment.bytes 配置的值；
●时间分片 当前日志分段中消息的最大时间戳与系统的时间戳的差值大于log.roll.ms配置的值；
●索引分片 偏移量或时间戳索引文件大小达到broker端 log.index.size.max.bytes配置的值；
●偏移分片 追加的消息的偏移量与当前日志分段的偏移量之间的差值大于 Integer.MAX_VALUE；
javaKafka面试题-如何查看偏移量为23的消息？
来源：图灵教育
时间：2024-05-26 13:25:07
通过查询跳跃表ConcurrentSkipListMap，定位到在00000000000000000000.index ，通过二分法在偏移量索引文件中找到不大于 23 的最大索引项，即offset 20 那栏，然后从日志分段文件中的物理位置为320 开始顺序查找偏移量为 23 的消息。
最新推荐
湘公网安备43019002002060