Camel路由转发至Azure Event Hub时出现编码错误求助

问题根源 #

你的Camel路由直接将REST端点接收到的org.apache.catalina.connector.RequestFacade对象转发给Azure Event Hub，但Event Hub的AMQP客户端无法编码这种复杂的Servlet请求对象，因此抛出编码错误。

解决方案 #

需要在转发前提取并转换REST请求的实际内容，将其转为Event Hub可处理的格式（如字符串、字节数组或JSON对象）。以下是几种可行的修改方式：

1. 直接转换请求体为字符串 #

在路由中添加convertBodyTo处理器，提取请求体并转为字符串：

@Component
public class RestEventHubRoute extends RouteBuilder {

    @Override
    public void configure() throws Exception {
        restConfiguration().component("servlet").bindingMode(RestBindingMode.auto);

        from("rest:post:/rest")
            .convertBodyTo(String.class) // 提取请求体并转为字符串格式
            .to("azure-eventhubs://?connectionString=Endpoint=xxx");
    }
}

2. 绑定到POJO（适用于结构化JSON请求） #

如果请求是JSON格式，可以绑定到自定义POJO，再序列化为JSON字符串转发：

// 自定义请求体对应的POJO
public class RequestPayload {
    private String content;
    // 生成getter、setter及构造方法
}

// 修改后的路由
@Component
public class RestEventHubRoute extends RouteBuilder {

    @Override
    public void configure() throws Exception {
        restConfiguration().component("servlet").bindingMode(RestBindingMode.json);

        from("rest:post:/rest?type=RequestPayload")
            .marshal().json() // 将POJO转为JSON字符串
            .to("azure-eventhubs://?connectionString=Endpoint=xxx");
    }
}

3. 提取原始字节数组 #

如果需要保留请求的二进制原始内容，可转为字节数组转发：

@Component
public class RestEventHubRoute extends RouteBuilder {

    @Override
    public void configure() throws Exception {
        restConfiguration().component("servlet").bindingMode(RestBindingMode.auto);

        from("rest:post:/rest")
            .convertBodyTo(byte[].class) // 提取原始二进制请求体
            .to("azure-eventhubs://?connectionString=Endpoint=xxx");
    }
}

关键说明 #

• RestBindingMode.auto会根据请求头自动绑定内容，但未明确指定时，Camel默认会把整个RequestFacade对象作为Exchange的body，而该对象无法被Event Hub编码。
• Azure Event Hub仅支持可序列化的简单类型（字符串、字节数组、JSON等），复杂对象必须先转换为这些格式后再转发。

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