Apache Camel升级至4.4.3后Azure Service Bus发送报错求助

问题原因 #

Camel 4.x版本的Azure Service Bus组件调整了消息属性的序列化逻辑，Azure SDK无法直接编码io.cloudevents.SpecVersion枚举类型，导致抛出编码未知的异常。

解决方案 #

1. 手动将SpecVersion转为字符串传递 #

在构建消息时，不要直接把SpecVersion枚举对象放入消息头部或属性，而是转为对应的字符串值（如"1.0"对应SpecVersion.V1）：

// 示例：构建CloudEvent并处理SpecVersion
CloudEvent cloudEvent = CloudEventBuilder.v1()
    .withId("event-1")
    .withType("com.example.event")
    .withSource(URI.create("/my-app"))
    .build();

// 转换SpecVersion为字符串后设置到消息头部
org.apache.camel.Message camelMsg = exchange.getMessage();
camelMsg.setHeader("ce-specversion", cloudEvent.getSpecVersion().toString());
// 其他消息内容设置...

2. 自定义消息转换器处理非标准类型 #

实现Camel的MessageConverter接口，在消息发送到Service Bus前，统一处理SpecVersion类型的属性：

@Component("customSbMessageConverter")
public class CustomServiceBusConverter implements MessageConverter {

    @Override
    public ServiceBusMessage toServiceBusMessage(org.apache.camel.Message camelMessage) {
        // 构建基础消息
        ServiceBusMessage sbMessage = new ServiceBusMessage(camelMessage.getBody(byte[].class));
        
        // 遍历并转换头部属性
        camelMessage.getHeaders().forEach((key, value) -> {
            if (value instanceof SpecVersion) {
                // 将SpecVersion转为字符串存入Service Bus属性
                sbMessage.addProperty(key, ((SpecVersion) value).toString());
            } else {
                // 其他类型直接传递（根据Azure SDK支持的类型调整）
                sbMessage.addProperty(key, value);
            }
        });
        
        return sbMessage;
    }

    // 忽略fromServiceBusMessage方法（如果不需要接收处理）
    @Override
    public org.apache.camel.Message fromServiceBusMessage(ServiceBusMessage sbMessage, Exchange exchange) {
        return exchange.getMessage();
    }
}

然后在路由中配置使用该转换器：

from("direct:sendToServiceBus")
    .to("azure-servicebus:my-namespace:my-queue?messageConverter=#customSbMessageConverter");

3. 禁用Camel的自动CloudEvent映射 #

检查Camel 4.x的Azure Service Bus组件配置，是否默认启用了CloudEvent的自动映射功能（如cloudEventsEnabled参数）。如果启用，尝试关闭该配置，手动构建符合要求的消息结构：

from("direct:sendToSb")
    .to("azure-servicebus:my-namespace:my-queue?cloudEventsEnabled=false");

内容的提问来源于stack exchange，提问作者Harish Guntha US