如何在 Mule 和 kafka 连接器使用者和生产者属性文件中设置加密密码

Question

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

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

骡子流中的骡子卡夫卡连接器代码。

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

任何人都可以建议如何在 Kafka 连接器属性文件中使用加密密码。

Answer 1

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

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