我正在寻找涉及一个使用kafka消费者和生产者的spring应用程序(别人的设计)的帮助。该设计允许config.properties文件包含如下条目:
Kafka地址=10.10.10.12:9093,10.10.10.11:9093,10.10.10.10:9093
这样的配置被某种像这样的Spring豆代码所拾取......
Java代码...
private String kafkaAddress;
public String getKafkaAddress() {
return kafkaAddress;
}
public void setKafkaAddress(String kafkaAddress) {
this.kafkaAddress = kafkaAddress;
}
它出现在我在调试器中看到的属性对象中。
“Kafka地址” -
代码将Properties对象传递给Kafka客户端的构造函数
我认为这一切都是通过spring的设计实现的,它将config“kafkaAddress”与匹配名称kafkaAddress的字符串相匹配
我想为ssl配置一些东西,比如...
ssl.truststore.location=C:\some\path\kafka.client.10.10.11.truststore。jks-ssl.truststore.password=mySecretWord
我在config中放了这些东西,但是我在setter和getter中放了什么呢?
我无法放置String ssl.truststore。位置,对吗?
在配置属性中,我使用...ssl_truststore_password=我的秘密密码
在MyConsumerConfig的setter和getter中。我使用的java文件。。。
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;
}
在调用构造函数. java文件之前…
if(StringUtils.isNotEmpty(myConsumerConfig.getSsl_truststore_password())) {
consumerProps.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG,
onlineConsumerConfig.getSsl_truststore_password());
}
SslConfigs。SSL_TRUSTSTORE_PASSWORD_CONFIG在包org.apache.kafka.common.CONFIG中定义。SslConfigs。。。
public static final String SSL_TRUSTSTORE_PASSWORD_CONFIG "ssl.truststore.password"
Spring框架将配置文件中的“ssl_truststore_password”链接到获取器和设置器,例如...
MyConsumerConfig.setSsl_truststore_password(String ssl_truststore_password)
我在我的MySQL服务器上设置了SSL。 我为CA(CA.pem,ca-key.pem)、客户端(client-cert.pem,client-key.pem)和服务器(server-cert.pem和server-key.pem)生成了几个证书。 在Spring Boot配置文件中,下面是到application.yml文件中定义的MySQL的链接:jdbc:MySQL:/host:3306/b
问题内容: 我将Spring Boot与Spring Security和Cors支持一起使用。 如果我执行以下代码 结果我得到了 如果我使用错误的凭证进行测试,例如 我得到的不是401(这是Spring安全中错误身份验证的标准代码) 带有以下浏览器通知: 获取http:// localhost:5000 / api / token XMLHttpRequest无法加载http:// localho
我使用带有Spring Security和Cors支持的Spring Boot。 带有以下浏览器通知: 获取http://localhost:5000/api/token XMLHttpRequest无法加载http://localhost:5000。请求的资源上没有“access-control-allow-origin”标头。因此,不允许访问源“http://localhost:3000”。响
我阅读了一些教程来在Spring Boot中配置LetsEncrypt SSL证书。我们有一个用spring Boot开发的应用程序。它运行在嵌入式Tomcat8080上。我有另一个角8应用程序,这是运行在默认的4200端口。在JWTToken的帮助下,两个应用程序都能够正确地相互通信。现在我希望我的应用程序/域应该是ssl启用。所以我的问题是,我们是否需要为两个应用程序单独的SSL证书,或者在S
我试图连接到Cassandra从我的Spring Boot应用程序使用Spring Boot数据cassandra。我有两个疑问。 1)是否建议使用CassandraAutoConfiguration,即在application.properties中提供带有前缀(spring.data.cassandra.*)的所有Cassandra配置,以便我的应用程序为我创建一个集群,或者我需要手动创建集群
我正在尝试用Kafka客户端设置一个Spring Boot应用程序以使用SSL。我有我的密钥库。jks和信任库。jk存储在文件系统(docker容器上)上,因为:https://github.com/spring-projects/spring-kafka/issues/710 以下是我的application.yml: 但是当我启动应用程序(在docker容器中)时,它说: 我检查了容器,.jk