| Consumer Offset | 消费组已提交的进度(下一条要读的位置) |
|---|---|
| Log End Offset | 分区当前末尾位置,即已写入条数 |
| Lag | LEO 与已提交位移之差,衡量积压 |
位移与积压查看
位移与积压查看
kafka-get-offsets.sh --bootstrap-server localhost:9092 --topic orders
# orders:0:1024
# orders:1:998
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group order-consumer位移提交的是“下一条要读的编号”而非“已读的编号”,重置位点时容易差一条,务必确认语义。