本地配置SalesforceSObjectSinkConnector时遇bootstrap.servers配置错误求助

核心问题定位 #

这个错误说明连接器未读取到有效的bootstrap.servers配置值，常见原因是配置位置错误、格式不符合要求，或者配置未被正确加载。

具体解决步骤 #

• 独立模式（Standalone）配置要点

  • bootstrap.servers必须写在全局配置文件（比如connect-standalone.properties）中，而非连接器专属的配置文件（如salesforce-sink.properties）。
  • 全局配置里采用字符串格式填写，无需数组：

    bootstrap.servers=localhost:9092
    # 多Broker场景用逗号分隔
    # bootstrap.servers=broker1:9092,broker2:9092
    

  • 启动命令要同时指定全局配置和连接器配置，确保配置加载完整：

    connect-standalone connect-standalone.properties salesforce-sink.properties
    

• 分布式模式（Distributed）配置要点

  • 提交连接器配置时，bootstrap.servers作为config字段下的顶级属性，用字符串格式填写，不要用数组：

    {
      "name": "salesforce-sink-connector",
      "config": {
        "bootstrap.servers": "localhost:9092",
        "connector.class": "io.confluent.connect.salesforce.SalesforceSObjectSinkConnector",
        "topics": "your-target-topic",
        // 其他Salesforce专属配置（如username、password、sobject.name等）
      }
    }
    

  • 用REST API提交配置的命令示例：

    curl -X POST -H "Content-Type: application/json" --data @connector-config.json http://localhost:8083/connectors
    

• 排查常见失误

  • 检查拼写：确认配置项是bootstrap.servers（末尾带s），不要误写成bootstrap.server。
  • 环境变量传递：如果用环境变量配置，变量名应为CONNECT_BOOTSTRAP_SERVERS，值为逗号分隔的字符串（如localhost:9092），避免数组格式。
  • 验证配置生效：分布式模式下可通过以下命令查看当前连接器配置，确认bootstrap.servers值是否正确：

    curl http://localhost:8083/connectors/salesforce-sink-connector/config
    

内容的提问来源于stack exchange，提问作者Leo AK