| 参数 | offsets.retention.minutes(2.0 起默认 10080 分钟,即 7 天) |
|---|---|
| 影响 | 过期后旧组位移丢失,等同新组 |
| 对策 | 长期停用的链路重启前核对起始位置与重放窗口 |
查看相关配置
查看相关配置
kafka-configs.sh --bootstrap-server localhost:9092 \
--entity-type brokers --entity-name 1 --describe | grep -i offsets.retention“停了几个月再启动还能接着消费”并不成立:位移过期后默认从最新读取,容易漏掉中间数据。