| 输出 | 主题:分区:位移 |
|---|---|
| 时间参数 | --time -1 最新，--time -2 最早，也可传毫秒时间戳 |
| 口径 | 取的是位移数值，不是消息条数（含空洞时两者不同） |
查询位移
查询位移
kafka-get-offsets.sh --bootstrap-server localhost:9092 --topic orders
# orders:0:1024
# orders:1:998
kafka-get-offsets.sh --bootstrap-server localhost:9092 --topic orders --time -2 # 最早
kafka-get-offsets.sh --bootstrap-server localhost:9092 --topic orders --time -1 # 最新老版本通过 kafka-run-class.sh kafka.tools.GetOffsetShell 调用；新版本发行包提供独立的 kafka-get-offsets.sh。