如何在 Mule 和 kafka 连接器消费者和生产者属性文件中设置加密密码答案

【问题标题】：How to set encrypted password in Mule and kafka connector consumer and producer properties file如何在 Mule 和 kafka 连接器消费者和生产者属性文件中设置加密密码
【发布时间】：2019-06-29 23:06:07
【问题描述】：

我有 Mule 应用程序并使用 Apache Kafka 连接器连接主题。 mule-kakfa 连接器 jar 是“mule-module-kafka-2.1.0.jar” 连接器使用 producer.properties 和 consumer.properties 文件，这些文件包含纯文本形式的“ssl.truststore.password”。您能否建议如何加密这些密码并在 mule flow 中使用。

我们使用的是 spring EnvironmentStringPBEConfig，但它不会解密 consumer.properties 和 producer.properties 文件中提供的密码。

mule 流程中的 Mule Kafka 连接器代码。

<apachekafka:config name="Apache_Kafka__Configuration" consumerPropertiesFile="consumer.properties" 
    producerPropertiesFile="producer.properties" doc:name="Apache Kafka: Configuration"/>

谁能建议如何在 Kafka 连接器属性文件中使用加密密码。

【问题讨论】：

就信任库而言——您根本不需要密码即可读取信任库。
@mazaneicha，感谢您的回复。我试过了，但它给出了异常 org.apache.kafka.common.security.ssl.SslFactory$SecurityStore.load
好的，谢谢！也许它是特定于 Kafka 的附加限制，因为通常只需要密码来添加/修改/删除信任库中的条目，例如参见 stackoverflow.com/questions/2343691/…

标签： apache-kafka mule

【解决方案1】：

这很可能无法完成。该文件要么在连接器内部处理，要么作为属性直接传递给 Kafka，因此应用程序中的任何其他加密层都不会看到它。这是 Mule 3 的连接器。

Mule 4 的连接器似乎允许将属性设置为键/值对。这将允许添加任何表达式或逻辑来解密值。

【讨论】：