如何使用信任存储和密码指定kafka adminclientconfig(kafka admin api)

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

如何使用信任存储和密码创建kafka adminclientconfig(kafka java admin api)。adminclientconfig有指定adminclientconfig.bootstrap\u servers\u config的方法,但如何指定“ssl.truststore.location”和“password”属性?
如果我们使用属性文件,如何用属性文件创建adminclientconfig?

bxpogfeg

bxpogfeg1#

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

相关问题