在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消费者/生产者应进行初始化。
实现这一目标的最佳方法是什么?
谢谢!
暂无答案!
目前还没有任何答案,快来回答吧!