代码之家  ›  专栏  ›  技术社区  ›  trougc

Nifi:如何在PublishJMS中将消息格式从MQHRF2更改为MQSTR?

  •  2
  • trougc  · 技术社区  · 6 年前

    我使用Flume将消息从HDFS发送到IBM MQ队列。但现在我们正在尝试Nifi这样做。除了消息格式不同之外,一切都正常。我在队列端得到的消息格式是MQHRF2。我需要将其更改为MQSRT格式。在PublishJMS中有没有这样做的方法,或者我应该在PublishJMS之前使用Nifi中的其他处理器来实现这一点?

    PublishJMS发送带有消息属性的XML头,最后是“消息”。我只需要将消息发送到队列,而不需要发送到标题。我认为这与上面提到的消息格式有一定关系,还是我错了?

    1 回复  |  直到 6 年前
        1
  •  2
  •   trougc    6 年前

    将Nifi PublishJMS中的目标名称更改为下面的代码段对我很有用

    queue:///theQueueName?targetClient=1
    

    感谢@JoshMC为我指引了正确的方向。