使用java.security.keystore对象的ssl kafkaadminclient对象

wr98u20j  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(289)

我需要创造 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 .
谁能帮我一下吗。

2w3rbyxf

2w3rbyxf1#

Kafka不支持 ssl 使用 java.security.keystore 对象。你可以看看 SslFactory 在Kafka上课了解更多信息。

相关问题