AI 助理
备案控制台
开发者社区 问答 正文

如何使用Kafka查看偏移量为23的消息？

如何使用Kafka查看偏移量为23的消息？

展开
收起
花开富贵111 2024-05-23 16:50:12 72 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 冲冲冲c

    通过查询跳跃表ConcurrentSkipListMap，定位到在00000000000000000000.index ，通过二分法在偏移量索引文件中找到不大于 23 的最大索引项，即offset 20 那栏，然后从日志分段文件中的物理位置为320 开始顺序查找偏移量为 23 的消息。1716460157180.png

    2024-05-23 17:03:25
    赞同 1 展开评论
问答分类：
消息中间件 Kafka 云消息队列 Kafka 版
问答标签：
云消息队列 Kafka 版偏移量
问答地址：
开发者社区 > 微服务 > 问答
相关问答
flink作业数据来源是kafka ，配置偏移量策略是earlest，有什么办法吗？
86
1
0
Flink1.14.4版本消费kafka数据，能外部保存偏移量并维护吗？
255
3
0
问一下 设置timestamp读 kafka 一直报错无效偏移量为啥 ?
260
2
0
flinksql消费kafka，没有消费记录的分区在sp的时候是不是不保存偏移量？
84
1
0
Flink CDC消费kafka停止后，使用sp启动，有的拿到的偏移量是-1，导致中间丢数据？
192
1
0
flink支持偏移量存在zookeeper的kafka消费吗？
239
1
0
使用原生的mq发到kafka，binlog日志的数据为什么没有偏移量信息。。写代码的时候可以拿到偏移
92
1
0
采集 binlog的变化同步到 kafka，这里 binlog每次的偏移量，存储在哪里
479
0
0
请问，我这边设置了upsert-kafka 连接器，，为啥读取出来的 主键 没有更新呢，偏移量还是增
682
1
0
flink消费kafka提交偏移量
2220
2
0