| 存储位置 | Kafka Connect offset.storage.topic(默认 connect-offsets) |
|---|---|
| 内容 | connector 位点:文件名/偏移或 GTID、事务信息 |
| 重启行为 | 从上次位点继续,不重新快照 |
| 重置方式 | 删除连接器重建并选择快照模式,或按官方工具调整位点 |
查看连接器状态与位点主题
查看连接器状态与位点主题
# 查看连接器与任务状态
curl -s http://kafka-connect:8083/connectors/mysql-cdc-orders/status
# 查看 offset 主题(只读排查,不要手改生产)
kafka-console-consumer.sh --bootstrap-server kafka1:9092 --topic connect-offsets --from-beginning --property print.key=true | head直接手改 connect-offsets 容易写坏 JSON 结构;需要重置时优先用“删除并重建连接器 + 快照模式”的标准路径。