在运行时提供kafka客户端属性以使用kafka身份验证

stszievb  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(160)

在micronaut kafka文档中有一些如何设置自定义属性的信息。通过 application.yml 文件或直接使用注解:

@KafkaClient(
    id="product-client",
    acks = KafkaClient.Acknowledge.ALL,
    properties = @Property(name = ProducerConfig.RETRIES_CONFIG, value = "5")
)
public interface ProductClient {
    ...
}

我必须提供 sasl.jaas.config 属性,因为客户端使用身份验证,并且在启动时解析机密。秘密解决后,Kafka消费者/生产者应进行初始化。
实现这一目标的最佳方法是什么?
谢谢!

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题