如何在NiFi的PublishJMS中将消息格式从MQHRF2改为MQSTR？

刚好之前做过NiFi对接IBM MQ的类似需求，给你一步步梳理处理方案：

1. 直接在PublishJMS中修改消息格式为MQSTR #

完全可以直接在PublishJMS处理器内配置实现，不需要额外搭配其他处理器，但要注意IBM MQ的特定配置细节：

• 首先确保PublishJMS使用的是IBM MQ官方JMS客户端（通过JNDI Properties File或Connection Factory参数配置正确的IBM MQ连接信息）。
• 在PublishJMS的属性面板中做以下配置：
  • 将Message Type设置为Text（这是对应MQSTR格式的基础消息类型）。
  • 添加用户自定义属性：点击属性区的+号，新增键为JMS_IBM_MsgType、值为8的配置项（IBM MQ中8对应MQSTR消息类型，而你当前的MQHRF2对应值是273）。
  • 如果之前开启了Add Message Properties，建议改为false，避免NiFi自动将FlowFile属性附加到MQ消息头部。

2. 仅发送消息体，去掉XML头和属性 #

这个需求和消息格式问题直接相关：

• 当消息格式改为MQSTR后，默认只会把FlowFile的内容作为纯消息体发送，不会附带MQHRF2格式自带的XML头部。但如果你的FlowFile本身（从HDFS读取的原始数据）就包含额外的XML头或属性内容，那需要先对FlowFile做预处理：
  • 用ExtractText处理器：通过正则表达式精准提取出你需要的核心消息体部分，覆盖原FlowFile内容。
  • 或用ReplaceText处理器：将不需要的XML头、属性片段替换为空，只保留目标消息体。
• 预处理后的FlowFile再传给PublishJMS，就能保证队列端只收到纯消息体内容。

快速验证方法 #

配置完成后，可以用IBM MQ的命令行工具runmqsc验证消息类型：

DISPLAY QLOCAL(你的目标队列名) MSGDSC

如果输出中看到MSGType(8)，说明已经成功发送MQSTR格式的消息了。

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