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