如何在NiFi PublishJMS处理器中修改IBM MQ消息的持久化模式?
解决NiFi PublishJMS发送IBM MQ消息改为Non-Persistent的问题
好问题!你完全不需要动MQ服务器端——毕竟你没权限嘛,直接在NiFi的PublishJMS处理器里就能配置搞定。
具体操作步骤:
- 打开PublishJMS处理器的配置面板,找到JMS Properties或者Advanced Configuration分组(不同NiFi版本位置可能略有差异,但核心属性肯定存在)。
- 找到名为
deliveryMode的配置项(有些版本会显示为可视化的Delivery Mode选项),它的可选值对应两种持久化状态:PERSISTENT:就是你当前的持久化模式NON_PERSISTENT:这就是你想要的非持久化模式
- 把属性值切换为
NON_PERSISTENT,保存配置后重启一下处理器(或者让NiFi自动加载新配置)。
补充说明:
这个deliveryMode是JMS规范里的标准属性,IBM MQ完全遵循这个规范——NiFi发送消息时会把这个模式传递给MQ服务器,服务器会直接按照这个设置处理消息的持久化状态,不需要你有MQ服务器的配置权限,只要你的PublishJMS连接正常就行。
改完之后你可以发一条测试消息,然后查看队列里的消息属性,就能确认持久化状态已经变成Non-Persistent啦。
内容的提问来源于stack exchange,提问作者trougc
相关产品推荐
相关产品推荐

