java - 如何使用信任存储和密码指定 Kafka AdminClientConfig (Kafka Admin api)

Question

如何使用信任存储和密码创建 Kafka AdminClientConfig(Kafka JAVA Admin api)。 AdminClientConfig 有方法指定 AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG 但我们如何指定“ssl.truststore.location”和“password”属性？

如果我们使用属性文件如何使用属性文件创建AdminClientConfig？

Answer 1

您为 AdminClient 指定 SSL 配置与其他客户端完全相同。

• 没有属性文件:

  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);