Spring Boot集成Camel消费Azure Event Hub消息失败，如何配置Kafka协议消费者？

你当前的配置存在以下核心问题，导致无法正常消费消息：

• 你在application.properties中定义的是原生Kafka的配置前缀，仅适用于Spring Kafka组件，Camel Kafka组件默认不会读取该前缀下的参数，导致SASL认证相关配置完全未生效
• 缺少必填的消费者组ID（group.id）参数，Azure Event Hub的Kafka协议适配层强制要求消费者必须指定消费组ID，否则会拒绝消费请求
• 未显式配置SSL endpoint校验算法，部分运行环境会因为证书校验逻辑缺失导致连接失败
• Camel路由的Kafka endpoint仅配置了Broker地址，没有传递任何认证相关参数，服务端认证失败直接拒绝连接请求

方式1：全局配置统一管理（推荐） #

直接在application.properties中配置Camel Kafka组件的全局参数，所有Kafka endpoint会自动复用该配置：

# Camel Kafka全局基础配置
camel.component.kafka.configuration.brokers=NAMESPACENAME.servicebus.windows.net:9093
camel.component.kafka.configuration.group-id=自定义消费组ID
# SASL认证配置
camel.component.kafka.configuration.security-protocol=SASL_SSL
camel.component.kafka.configuration.sasl-mechanism=PLAIN
camel.component.kafka.configuration.sasl-jaas-config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="替换为你的Azure Event Hub连接字符串";
# SSL校验配置
camel.component.kafka.configuration.ssl-endpoint-identification-algorithm=https
# 可选：测试场景下配置从最早消息开始消费
camel.component.kafka.configuration.auto-offset-reset=earliest

对应路由代码可直接简化为：

from("kafka:{{topicName}}")
        .log("Message received from Kafka : ${body}");

方式2：直接在Endpoint中传递全部参数 #

如果不需要全局复用配置，可将所有参数直接拼接在Kafka endpoint的URI中：

from("kafka:{{topicName}}?brokers=NAMESPACENAME.servicebus.windows.net:9093" +
                "&groupId=自定义消费组ID" +
                "&securityProtocol=SASL_SSL" +
                "&saslMechanism=PLAIN" +
                "&saslJaasConfig=org.apache.kafka.common.security.plain.PlainLoginModule required username=\"$ConnectionString\" password=\"替换为你的Azure Event Hub连接字符串\";" +
                "&sslEndpointIdentificationAlgorithm=https" +
                "&autoOffsetReset=earliest")
        .log("Message received from Kafka : ${body}");

排查校验点 #

• 确认你使用的Event Hub连接字符串具备对应事件中心的消费权限，连接字符串可从Azure门户事件中心命名空间的「共享访问策略」处获取
• 确认配置文件中的topicName和Azure上创建的事件中心名称完全一致
• 确认运行环境的网络可以正常访问NAMESPACENAME.servicebus.windows.net:9093端口，无防火墙或代理拦截

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