我需要创造 kafkaAmdinClient
ssl对象使用 java.security.keystore
对象。i、 e我必须从数据库中读取keystore和truststire文件作为clob并将keystore放入 java.security.keystore
对象并使用它创建管理客户端对象。
我能创造 AdminClient
对象使用属性对象:
props.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG, trustStorePwd);
props.put(SslConfigs.SSL_KEYSTORE_LOCATION_CONFIG, "/ngs/app/bolt_components/kafka_ssl/RN_BC_YELLOWBIRD/client.truststore.jks");
props.put(SslConfigs.SSL_KEYSTORE_PASSWORD_CONFIG, keyStorePwd);
kafkaAdminClient = AdminClient.create(props);
但根据要求,我不应该指定密钥库文件的位置。而是指定keystore对象。
KeyStoreDto kDto=KeystoreManager.getKafkaKeyStoreDto(kafkaDto.getKEYSTORE_ID());
java.security.KeyStore keyStore = kDto.getKeyStore();
java.security.KeyStore trustStore = kDto.getTrustStore();
String keyStorePwd=kDto.getKeyStorePassword();
String trustStorePwd=kDto.getTrustStorePassword();
从这个我必须使用 keyStore
以及 trustStore
.
谁能帮我一下吗。
1条答案
按热度按时间2w3rbyxf1#
Kafka不支持
ssl
使用java.security.keystore
对象。你可以看看SslFactory
在Kafka上课了解更多信息。