WSO2 EI 6.1.1自定义二进制消息构建器处理IBM遗留系统数据问题

针对你遇到的问题——自定义了二进制消息构建器但Kafka入站端点仍无法处理IBM遗留系统的二进制消息，我整理了几个关键排查方向和解决方法，一步步来：

1. 先确认自定义构建器的Axis2配置是否生效 #

WSO2 EI的消息构建器是按配置顺序匹配的，如果你的自定义构建器排在默认构建器后面，可能根本没被触发：

• 打开EI_HOME/conf/axis2/axis2.xml，找到你的<messageBuilder>配置，确保它在默认的application/octet-stream构建器之前。比如：

<!-- 自定义IBM二进制消息构建器，放在前面优先匹配 -->
<messageBuilder contentType="application/ibm-legacy-binary" class="com.yourcompany.builders.IBMMessageBuilder"/>
<!-- 默认二进制构建器 -->
<messageBuilder contentType="application/octet-stream" class="org.apache.axis2.format.BinaryBuilder"/>

• 检查contentType是否和Kafka消息携带的Content-Type完全一致。如果Kafka消息没指定Content-Type，要么在入站端点强制指定，要么把自定义构建器的contentType设为application/octet-stream（但要注意覆盖默认的话可能影响其他场景）。
• 核对构建器的类名是否完全正确（包名+类名），别犯拼写错误。

2. 验证构建器JAR的部署与类加载 #

• 确认JAR确实放在了EI_HOME/lib目录，然后重启WSO2 EI——新放入的JAR需要重启才能加载。
• 查看启动日志EI_HOME/repository/logs/wso2carbon.log，搜索你的构建器类名，看是否有ClassNotFoundException或者类加载成功的日志。如果有类加载失败，大概率是JAR依赖缺失，或者放错了目录。

3. 检查Kafka入站端点的配置细节 #

Kafka入站端点需要明确告知EI该用什么构建器处理消息：

• 在入站端点的参数中添加contentType，指定为你的构建器对应的类型，比如：

<inboundEndpoint xmlns="http://ws.apache.org/ns/synapse" name="IBM_Kafka_Inbound" sequence="Binary_To_XML_Sequence" onError="Error_Sequence" protocol="kafka" suspend="false">
    <parameters>
        <parameter name="inbound.kafka.topic">ibm-legacy-topic</parameter>
        <parameter name="inbound.kafka.bootstrap.servers">kafka-host:9092</parameter>
        <!-- 强制指定消息类型，触发自定义构建器 -->
        <parameter name="contentType">application/ibm-legacy-binary</parameter>
        <!-- 其他Kafka配置参数 -->
    </parameters>
</inboundEndpoint>

如果不指定，EI可能会用默认的二进制构建器，导致你的自定义逻辑不生效。

4. 加日志调试，看清消息处理流程 #

在处理序列里加日志 mediator，打印关键信息，确认构建器是否被调用：

<log level="full">
    <property name="Current_Content_Type" expression="$trp:Content-Type"/>
    <property name="Used_Message_Builder" expression="get-property('MESSAGE_BUILDER')"/>
</log>

查看日志里的Used_Message_Builder值，如果不是你的自定义构建器类名，说明前面的配置有问题；如果是，那就要检查构建器本身的逻辑了。

5. 单独验证自定义构建器的逻辑 #

把构建器的逻辑抽出来单独测试：写个简单的Java类，读取IBM遗留系统的二进制样本文件，调用构建器的processDocument方法，看是否能生成正确的XML/文本。如果这一步都失败，说明构建器的转换逻辑有bug，得先修复这个。

总结解决步骤 #

1. 调整axis2.xml中构建器的顺序，让自定义构建器优先匹配。
2. 确认JAR部署正确，重启EI并检查类加载日志。
3. 在Kafka入站端点中明确指定contentType，触发自定义构建器。
4. 加日志调试，确认构建器是否被调用。
5. 单独测试构建器的转换逻辑，修复可能的bug。

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