首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
您找到你想要的搜索结果了吗?
是的
没有找到

解惑 | 为什么我根据时间获得offset为空呢?

每一个成功人士背后,必定曾经做出过勇敢而又孤独决定。 放弃不难,但坚持很酷~ kafka_2.11-1.1.0 一、前言 最近有一个需求,要查询某一时间对应offset值,于是就想到了使用 ....但是明明指定时间有上报数据,肯定有对应 offset 。...,其中 -1 会输出最新 offset ;-2 会输出未过期最小 offset ;时间这里具有迷惑性,它不能根据时间获取到精准匹配 offset 。...每一个 xxx.log 文件都算作一个 segment,kafka.tools.GetOffsetShell --time 参数匹配是 xxx.log 文件本身最后修改时间,而不是偏移量本身时间...三、调用 kafka java api 获取时间对应 offset,并封装成工具脚本 很纳闷,为什么官方不提供获取时间对应精准 offset 呢?

2.6K30
领券