如何在ksnap备份命令中传递Kafka客户端属性？

ksnap支持两种方式传入Kafka客户端的SSL配置属性，以此解决因缺少安全配置导致的“socket disconnected”错误：

方式一：通过配置文件批量传递属性 #

1. 创建一个Kafka客户端配置文件（比如kafka-ssl.properties），填入所需的安全属性：

security.protocol=SSL
ssl.keystore.location=/绝对路径/到/你的keystore.jks
ssl.keystore.password=你的密钥库密码
ssl.truststore.location=/绝对路径/到/你的truststore.jks
ssl.truststore.password=你的信任库密码
# 若集群要求客户端双向认证，额外添加：
ssl.key.password=你的密钥密码

2. 在备份命令中通过--config参数引用该文件：

ksnap backup -b kafka.internal.cloudapp.net:9092 -t t1,t2,t3,t4,t5 -d ./backupDir --config kafka-ssl.properties

方式二：通过-X参数逐个指定属性 #

直接在命令行中用-X前缀逐个传递每个SSL属性，适合临时测试或少量配置的场景：

ksnap backup -b kafka.internal.cloudapp.net:9092 -t t1,t2,t3,t4,t5 -d ./backupDir \
-X security.protocol=SSL \
-X ssl.keystore.location=/绝对路径/到/你的keystore.jks \
-X ssl.keystore.password=你的密钥库密码 \
-X ssl.truststore.location=/绝对路径/到/你的truststore.jks \
-X ssl.truststore.password=你的信任库密码

关于“socket disconnected”错误的说明 #

该错误大多是因为Kafka集群启用了SSL加密，但ksnap客户端未提供有效的SSL配置，导致连接握手失败后被断开。请确保：

• 所有SSL属性的路径是绝对路径，且ksnap进程有读取对应文件的权限
• 配置的密码与keystore/truststore的实际密码完全一致
• 若集群开启双向认证，必须添加ssl.key.password属性

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