我按照这篇文章尝试了使用 Apache Storm 的 eventthub,但是当我运行 Storm 拓扑时,它正在接收事件一分钟,然后它停止接收。所以我重新启动了我的程序,然后它正在接收剩余的消息。每次我在一分钟后运行程序时,它都无法从 eventthub 接收到。请帮助我解决问题的可能性...
我应该更改 Storm 或 Zookeeper 的任何配置吗?
我按照这篇文章尝试了使用 Apache Storm 的 eventthub,但是当我运行 Storm 拓扑时,它正在接收事件一分钟,然后它停止接收。所以我重新启动了我的程序,然后它正在接收剩余的消息。每次我在一分钟后运行程序时,它都无法从 eventthub 接收到。请帮助我解决问题的可能性...
我应该更改 Storm 或 Zookeeper 的任何配置吗?
上面的 jar 包含对 QPID JMS 客户端中一个已知问题的修复,该客户端由 Event Hub spout 实现使用。当服务发送空帧(保持连接活动的心跳)时,客户端会发生解码错误,导致客户端停止处理命令。可以在此处找到此问题的详细信息:https ://issues.apache.org/jira/browse/QPID-6378