在运行时提供 Kafka Client 属性以使用 kafka auth答案

【问题标题】：Provide Kafka Client property at runtime to use kafka auth在运行时提供 Kafka Client 属性以使用 kafka auth
【发布时间】：2020-08-28 18:33:51
【问题描述】：

在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 消费者/生产者。

实现这一目标的最佳方法是什么？

谢谢！

【问题讨论】：

标签： apache-kafka micronaut

【解决方案1】：

我认为 micronaut 在当前版本中没有此设置。

但是您可以在 application.yml 中的生产者配置下添加这一行：

sasl.jaas.config: com.sun.security.auth.module.Krb5LoginModule 需要 blablabla";

并通过如下占位符阅读：

属性(name = "sasl.jaas.config", value = "${kafka.producers.your_producer_id.sasl.jaas.config}")

【讨论】：