connect-distributed.properties 关键项
connect-distributed.properties 关键项
bootstrap.servers=kafka1:9092,kafka2:9092,kafka3:9092
group.id=debezium-cluster
key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
key.converter.schemas.enable=false
value.converter.schemas.enable=false
offset.storage.topic=connect-offsets
config.storage.topic=connect-configs
status.storage.topic=connect-status
offset.storage.replication.factor=3| distributed | 生产推荐：多 worker 组集群，REST 接口增删连接器 |
|---|---|
| standalone | 单机开发调试，配置与位点存本地文件 |
| 内部主题 | config 必须 compacted，offset/status 由 Connect 维护 |
| 转换器 | 决定了消息序列化格式（JSON/Avro 等），要先与下游约定 |
生产环境的内部主题副本数建议与业务关键主题一致，避免单 Broker 故障丢失连接器配置。