Nifi Publish Amqp to RabbitMQ 格式错误的数据错误

问题描述

我有 2 个处理器,其中一个是从兔子成功消费的“ConsumeAmqp”,另一个获取消费数据并推送另一个队列的“PublishAmqp”。

enter image description here

如何将消耗标头和正文的数据从 ConsumeAMQP 处理器传递到 Publish AMQP 处理器?

我尝试创建新的属性名称作为标头和有效负载,但我无法使用消费填充数据。

我的 updateAttribute 像这样但不起作用。

enter image description here

错误是这样的“ PublishAMQP[id=1759fd41-0178-1000-23fe-815361cddee2] AMQP 标头属性的格式错误的键值对:{}"

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)