Snowflake Kafka Connector私钥环境变量无法解密问题求助

1. 优先用 Kafka Connect 原生环境变量引用，别自己用 sed 替换 #

Kafka Connect 本身支持在配置里直接用 ${变量名} 读取环境变量，完全不需要 sed 脚本折腾。你的 JSON 配置可以直接这么写：

{
  "name": "snowflake-kafka-connector",
  "config": {
    "snowflake.private.key": "${PRIVATE_KEY}",
    "snowflake.private.key.passphrase": "${PRIVATE_KEY_PASSPHRASE}",
    // 其他配置项...
  }
}

提交时直接用 curl 发送这个原始 JSON 文件就行，Kafka Connect 会自动解析环境变量，不会破坏私钥格式。

2. 非要用 sed 的话，必须保证私钥格式完整 #

私钥是带换行的 PEM 格式，sed 替换时很容易把换行符弄丢，变成一行乱码，导致 Snowflake 无法解析。你需要先把环境变量里的私钥转义处理：

# 把私钥里的换行转成 \n，同时转义反斜杠
export ESCAPED_PRIVATE_KEY=$(echo "$PRIVATE_KEY" | sed 's/\\/\\\\/g; s/\n/\\n/g')
# 替换 JSON 里的占位符
sed "s/\$PRIVATE_KEY/$ESCAPED_PRIVATE_KEY/g" your-config.json > fixed-config.json
# 提交时确保 curl 能解析转义后的换行
curl -X POST -H "Content-Type: application/json" --data @fixed-config.json http://your-kafka-connect-url:8083/connectors

但这种方法容易出各种格式问题，还是推荐用第一种原生方式。

3. 别用 {{env_var($PRIVATE_KEY)}} 格式 #

这种语法不是 Kafka Connect 原生支持的，属于第三方模板引擎的写法，Kafka Connect 根本识别不了，别浪费时间试这个。

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