SSL KafkaAdminClient объект с использованием объекта java.security.Keystore

Question

Мне нужно создать kafkaAmdinClient объект SSL с использованием объекта java.security.keystore. Т.е. мне нужно прочитать файлы хранилища ключей и доверенных сертификатов из базы данных в виде сгустка, получить хранилище ключей в объекте java.security.keystore и использовать его для создания объекта клиента Admin.

Я могу создать 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);

Но в соответствии с requiremtn я не должен указывать расположение файла хранилища ключей. Вместо этого укажите объект хранилища ключей.

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.

Может ли кто-нибудь помочь мне с этим.

Answer 1

Кафка не поддерживает ssl, используя java.security.keystore объект. Вы можете заглянуть в SslFactory класс по kafka для получения дополнительной информации.