Apache Camel集成Azure Event Hubs无法接收消息问题求助

在使用Apache Camel集成Azure Event Hubs时，遇到无法接收消息的问题，相关代码如下：

from("azure-eventhubs:? connectionString=RAW(<CONNECTION_STRING>)&credentialType=CONNECTION_  STRING&blobContainerName=BLOCB&blobAccountName=ACNAME&blobAccessKey=RAW(<<KEY>>)").process(exchange -> { String body = exchange.getIn().getBody(String.class);
exchange.getIn().setHeader(EventHubsConstants.PARTITION_ID, 4);
System.out.println(body);
System.out.println("Message received successfully"); 
}).to("mock:result");

问题排查与修正要点 #

• 配置参数错误：
  • credentialType参数值CONNECTION_ STRING包含多余空格，需改为CONNECTION_STRING
  • blobContainerName拼写错误：BLOCB应为BLOB
  • blobAccessKey的RAW语法错误：RAW(<<KEY>>)多了一层尖括号，需改为RAW(<KEY>)
• 分区ID设置时机错误：
  在process处理器中设置EventHubsConstants.PARTITION_ID是无效的，该参数是用来指定消费者要监听的分区，需直接在端点配置中添加partitionId=4
• 存储账户权限验证：
  确保配置的Blob存储账户拥有容器的读写权限，Event Hubs消费者依赖Blob存储持久化消费偏移量，权限不足会导致无法拉取消息
• 依赖版本兼容性：
  确认Camel Azure Event Hubs组件版本与Camel核心版本匹配，版本不兼容可能引发连接或消费异常
• 日志调试：
  开启Camel DEBUG级日志，查看是否有连接失败、权限报错、偏移量读取失败等日志，精准定位问题

修正后的示例代码 #

from("azure-eventhubs:?connectionString=RAW(<CONNECTION_STRING>)&credentialType=CONNECTION_STRING&blobContainerName=BLOB&blobAccountName=ACNAME&blobAccessKey=RAW(<KEY>)&partitionId=4")
    .process(exchange -> {
        String body = exchange.getIn().getBody(String.class);
        System.out.println(body);
        System.out.println("Message received successfully"); 
    })
    .to("mock:result");

内容的提问来源于stack exchange，提问作者Dharanidharan.T