如何在spring应用程序中配置ssl工件?

r3i60tvu  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(333)

我正在寻找帮助,涉及一个spring应用程序(其他人的设计),使用Kafka消费者和生产者。这种设计允许config.properties文件包含如下条目:
Kafka地址=10.10.10.12:9093,10.10.10.11:9093,10.10.10:9093
这样的配置是由类似这样的springbean代码获取的。。。
java代码。。。

private String kafkaAddress;

public String getKafkaAddress() {
   return kafkaAddress;
}

public void setKafkaAddress(String kafkaAddress) {
   this.kafkaAddress = kafkaAddress;
}

它出现在我用调试器看到的properties对象中。
“Kafka地址”->“10.10.10.12:9093,10.10.10.11:9093,10.10.10:9093”
代码将properties对象传递给kafka客户机的构造函数
我认为这一切都是通过spring的设计和匹配配置“kafkaaddress”以及匹配名称kafkaaddress的字符串实现的
好吧,我想配置ssl,比如。。。
ssl.truststore.location=c:\some\path\kafka.client.10.10.11.truststore.jks ssl.truststore.password=mysecretword
我把这样的东西放在配置中,但是我该把什么放在我的setter和getter中呢?
我不能放字符串ssl.truststore.location,对吗?

t3psigkw

t3psigkw1#

在config.properties中我使用。。。ssl\u truststore\u password=mysecretpassword
在myconsumerconfig.java文件的setters和getter中,我使用。。。

public void setSsl_truststore_password(String ssl_truststore_password ) {
    this.ssl_truststore_password = ssl_truststore_password;
}
public String getSsl_truststore_password() {
    return this.ssl_truststore_password;
}

在调用constructor.java文件之前。。。

if(StringUtils.isNotEmpty(myConsumerConfig.getSsl_truststore_password())) {
        consumerProps.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG,
                onlineConsumerConfig.getSsl_truststore_password());
    }

sslconfigs.ssl\u truststore\u password\u config在org.apache.kafka.common.config.sslconfigs包中定义。。。

public static final String  SSL_TRUSTSTORE_PASSWORD_CONFIG  "ssl.truststore.password"

spring框架将配置文件中的“ssl\u truststore\u password”链接到getter和setter,例如。。。

MyConsumerConfig.setSsl_truststore_password(String ssl_truststore_password)

相关问题