我正在寻找帮助,涉及一个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,对吗?
1条答案
按热度按时间t3psigkw1#
在config.properties中我使用。。。ssl\u truststore\u password=mysecretpassword
在myconsumerconfig.java文件的setters和getter中,我使用。。。
在调用constructor.java文件之前。。。
sslconfigs.ssl\u truststore\u password\u config在org.apache.kafka.common.config.sslconfigs包中定义。。。
spring框架将配置文件中的“ssl\u truststore\u password”链接到getter和setter,例如。。。