Kafka Connect：如何从自定义 SMT 的 connect-distributed.properties 读取/访问属性？答案

【问题标题】：Kafka Connect: How can I read/access properties from the connect-distributed.properties from my custom SMT?Kafka Connect：如何从自定义 SMT 的 connect-distributed.properties 读取/访问属性？
【发布时间】：2021-08-27 01:55:32
【问题描述】：

我正在使用 Kafka Connect JDBC 源连接器和自定义 SMT。我想从 connect-distributed.properties 文件访问信任库和密钥库位置以及它们各自的密码。例如以下部分：

ssl.truststore.location=/opt/myapp/config/truststore.jks
ssl.truststore.password=mypassword
ssl.keystore.location=/opt/myapp/config/keystore.jks
ssl.keystore.password=mypassword
ssl.key.password=mypassword

如何在我的 SMT 内部实现？这更倾向于以下部分：

javax.net.ssl.trustStore
javax.net.ssl.keyStore
KAFKA_OPTS="-Djavax.net.ssl.trustStore=${CERTS_PATH}/truststore.jks -Djavax.net.ssl.trustStorePassword=$TRUSTSTORE_PASSWORD -Djavax.net.ssl.keyStore=${CERTS_PATH}/keystore.jks -Djavax.net.ssl.keyStorePassword=$KEYSTORE_PASSWORD -Djavax.net.ssl.keyPassword=$KEY_PASSWORD"

如果我不把上面的，从我的自定义 SMT 的架构注册表调用，抛出 bad_certificate 异常。我知道我可以将这些属性设置为 ConfigDef 的一部分，但是公开凭据就不太好了。

谢谢

【问题讨论】：

标签： apache-kafka apache-kafka-connect confluent-schema-registry

【解决方案1】：

您的转换不需要这些文件。它与连接工作线程在同一个 JVM 下运行，连接工作线程已经过身份验证。

您的 SMT 也应该只使用 Struct/Schema 对象，而不是使用 Regsistry HTTP 客户端操作的 Converter 或 Serializer 类。

【讨论】：