Quarkus中SmallRye Kafka多通道不同Bootstrap Server认证配置问题

问题分析 #

你遇到的Could not find a 'KafkaClient' entry in the JAAS configuration错误，根源是通道配置未正确传递给底层Kafka生产者客户端。SmallRye Kafka扩展要求Kafka原生配置项（如bootstrap.servers、sasl.jaas.config等）必须以kafka.为前缀，否则扩展无法识别这些配置，导致Kafka客户端尝试加载默认JAAS配置但未找到，最终启动失败。

解决方案 #

以下两种方案均可解决多通道不同Kafka集群的SASL_SSL认证问题：

方案一：修正通道配置，添加kafka.前缀

直接为每个通道的Kafka原生配置项添加kafka.前缀，确保SmallRye扩展将配置传递给Kafka客户端：

# 通道1配置（替换your-topic-name-1为实际主题名）
mp.messaging.outgoing.channel1.topic=your-topic-name-1
mp.messaging.outgoing.channel1.kafka.bootstrap.servers=${KAFKA1}
mp.messaging.outgoing.channel1.kafka.ssl.endpoint-identification-algorithm=https
mp.messaging.outgoing.channel1.kafka.security.protocol=SASL_SSL
mp.messaging.outgoing.channel1.kafka.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="${KEY1}" password="${PWD1}";
mp.messaging.outgoing.channel1.kafka.sasl.mechanism=PLAIN

# 通道2配置（替换your-topic-name-2为实际主题名）
mp.messaging.outgoing.channel2.topic=your-topic-name-2
mp.messaging.outgoing.channel2.kafka.bootstrap.servers=${KAFKA2}
mp.messaging.outgoing.channel2.kafka.ssl.endpoint-identification-algorithm=https
mp.messaging.outgoing.channel2.kafka.security.protocol=SASL_SSL
mp.messaging.outgoing.channel2.kafka.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="${KEY2}" password="${PWD2}";
mp.messaging.outgoing.channel2.kafka.sasl.mechanism=PLAIN

方案二：定义独立Kafka客户端，通道引用客户端

先在全局配置中定义两个独立的Kafka客户端配置，再让通道指定使用对应的客户端，这种方式更适合复杂场景的配置复用：

# 定义客户端1的全局配置
quarkus.kafka.clients.client1.bootstrap.servers=${KAFKA1}
quarkus.kafka.clients.client1.ssl.endpoint-identification-algorithm=https
quarkus.kafka.clients.client1.security.protocol=SASL_SSL
quarkus.kafka.clients.client1.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="${KEY1}" password="${PWD1}";
quarkus.kafka.clients.client1.sasl.mechanism=PLAIN

# 定义客户端2的全局配置
quarkus.kafka.clients.client2.bootstrap.servers=${KAFKA2}
quarkus.kafka.clients.client2.ssl.endpoint-identification-algorithm=https
quarkus.kafka.clients.client2.security.protocol=SASL_SSL
quarkus.kafka.clients.client2.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="${KEY2}" password="${PWD2}";
quarkus.kafka.clients.client2.sasl.mechanism=PLAIN

# 通道1引用客户端1
mp.messaging.outgoing.channel1.topic=your-topic-name-1
mp.messaging.outgoing.channel1.kafka.client-id=client1

# 通道2引用客户端2
mp.messaging.outgoing.channel2.topic=your-topic-name-2
mp.messaging.outgoing.channel2.kafka.client-id=client2

注意事项 #

• 删除之前的全局kafka.*配置，避免配置优先级冲突
• 确认环境变量${KAFKA1}、${KEY1}、${KAFKA2}、${KEY2}已正确注入到应用中
• 确保目标Kafka集群已启用SASL_PLAIN认证机制，且用户名密码权限正确

内容的提问来源于stack exchange，提问作者Hugo Pais