| 两类连接器 | source（外部→Kafka）、sink（Kafka→外部） |
|---|---|
| 运行 | standalone 或 distributed worker，distributed 支持横向扩展与故障转移 |
| 组件 | converter（数据格式）、SMT（单消息转换）、offset/status 主题 |
通过 REST 创建连接器
通过 REST 创建连接器
curl -X POST -H "Content-Type: application/json" \
--data @file-sink.json \
http://localhost:8083/connectors
curl -s http://localhost:8083/connectors | jq
curl -s http://localhost:8083/connector-plugins | jq '.[].class'连接器状态放在 connect-status 主题、位移放在 connect-offsets 主题，重启 worker 后从位移续传。