Nifi：如何在 PublishJMS 中将消息格式从 MQHRF2 更改为 MQSTR？
Nifi: How can I change message format from MQHRF2 to MQSTR in PublishJMS?
我正在使用 Flume 将消息从 HDFS 发送到 IBM MQ Queue。但现在我们正在尝试 Nifi 这样做。除了消息格式不同外，一切正常。我在 Queue 端得到的消息格式是 MQHRF2。我需要将其更改为 MQSRT 格式。有没有办法在 PublishJMS 中做到这一点，或者我应该在 PublishJMS 之前在 Nifi 中使用其他处理器来实现它？
PublishJMS 正在发送带有消息属性的 XML headers，最后 "the-message"。我只需要将消息发送到 queue 而不是 headers。我认为这与上面提到的消息格式有些关系还是我错了？
将 Nifi PublishJMS 中的目标名称更改为下面的代码片段对我有用
queue:///theQueueName?targetClient=1
感谢@JoshMC 指导我正确的方向。
我正在使用 Flume 将消息从 HDFS 发送到 IBM MQ Queue。但现在我们正在尝试 Nifi 这样做。除了消息格式不同外，一切正常。我在 Queue 端得到的消息格式是 MQHRF2。我需要将其更改为 MQSRT 格式。有没有办法在 PublishJMS 中做到这一点，或者我应该在 PublishJMS 之前在 Nifi 中使用其他处理器来实现它？
PublishJMS 正在发送带有消息属性的 XML headers，最后 "the-message"。我只需要将消息发送到 queue 而不是 headers。我认为这与上面提到的消息格式有些关系还是我错了？
将 Nifi PublishJMS 中的目标名称更改为下面的代码片段对我有用
queue:///theQueueName?targetClient=1
感谢@JoshMC 指导我正确的方向。