Как указать Kafka AdminClientConfig (Kafka Admin api) с доверенным хранилищем и паролем

Question

Как создать Kafka AdminClientConfig (Kafka JAVA Admin api) с доверенным хранилищем и паролем. AdminClientConfig имеет метод для указания AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, но как мы можем указать свойства "ssl.truststore.location" и "password"?

Если мы используем файл свойств, как создать AdminClientConfig с файлом свойств?

Answer 1

Вы указываете конфигурации SSL для AdminClient точно так же, как в других клиентах.

• Без файла свойств:

  Properties adminProps = new Properties();
  adminProps.put(...)
  adminProps.put(SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG, "some/path/truststore");
  adminProps.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG, "password");
  
  AdminClient admin = KafkaAdminClient.create(adminProps);
  

• С файлом свойств:

  В admin.properties:

  bootstrap.servers=localhost:9092
  ...
  ssl.truststore.location=some/path/truststore
  ssl.truststore.password=password
  

  Тогда в вашем коде Java:

  Properties adminProps = new Properties();
  adminProps.load(new FileInputStream("admin.properties"));
  AdminClient admin = KafkaAdminClient.create(adminProps);