Kafka Offset 追踪

Consumer Offset 机制可视化
预设场景
Topic 配置
Offset 提交策略
模拟操作

__consumer_offsets

Kafka 将 offset 存储在内部 Topic __consumer_offsets 中(50个分区)。Key = group+topic+partition,Value = offset。Consumer 重启后从此处恢复消费位置。

At-Least-Once
先处理再提交 · 可能重复
At-Most-Once
先提交再处理 · 可能丢失
Exactly-Once
事务性提交 · 不丢不重
0
已生产
0
已消费
0
已提交Offset
0
Consumer Lag
0
重复/丢失
Kafka Offset 追踪 · 3 分区 · 3 消费者 · 自动提交