错误信息中显示 找不到 default 流id
但是报错之后的地方依然能正常得到信息
错误信息中显示 找不到 default 流id
但是报错之后的地方依然能正常得到信息
这个问题可能是由于 Storm 拓扑定义的输出流 ID 与 RMQ_PubNub 定义的输出流 ID 不匹配导致的。具体解决方案如下:
确认拓扑中定义的输出流 ID 是否与 RMQ_PubNub 中定义的输出流 ID 匹配。可以在拓扑定义中查找输出流 ID,然后在 RMQ_PubNub 定义中确认是否使用了相同的输出流 ID。
如果 ID 匹配,可以尝试延长消息超时时间。可以在 RMQ_PubNub 中增加超时时间,确保消息能够及时到达 Storm。例如,可以将默认的超时时间增加到更长的时间。
如果以上两个方法都无法解决问题,可以考虑降低拓扑中的并发度。可以将拓扑中的并发度降低到较低的水平,以减少处理延迟和数据传输问题。