我跟随本文尝试使用ApacheStorm的eventhub,但是当我运行storm拓扑时,它接收了一分钟的事件,然后就停止了接收。所以我重启了我的程序,然后它收到了剩下的消息。每次我在一分钟后运行程序时,它都无法从eventhub接收到消息。请帮助我解决这个问题的可能性。。。我应该在storm或zookeeper更改任何配置吗。
gmxoilav1#
上面的jar包含对qpid jms客户机中的已知问题的修复,该问题由事件中心spout实现使用。当服务发送一个空帧(保持连接活动的心跳信号)时,客户端会发生解码错误,导致客户端停止处理命令。有关此问题的详细信息,请参见:https://issues.apache.org/jira/browse/qpid-6378
1条答案
按热度按时间gmxoilav1#
上面的jar包含对qpid jms客户机中的已知问题的修复,该问题由事件中心spout实现使用。当服务发送一个空帧(保持连接活动的心跳信号)时,客户端会发生解码错误,导致客户端停止处理命令。有关此问题的详细信息,请参见:https://issues.apache.org/jira/browse/qpid-6378