我的拓扑有一两个瓶颈。 Storm UI 中的容量指标对于识别这些非常有用，但我对 Bolt 队列的大小更感兴趣。
我的理解是每个螺栓有两个队列，一个用于待执行的元组，另一个用于待发出的元组。是否可以监控这些队列的大小？
我在网上找到了一些关于向 Bolts 添加 ITaskHook 实现的内容，但还不清楚如何使用它来监视队列大小。可以使用 ITaskHook 中的方法来监控吗？
您应该能够使用以下命令查看拓扑组件的队列长度metrics http://storm.apache.org/documentation/Metrics.html机制。一个简单的方法是添加conf.registerMetricsConsumer(LoggingMetricsConsumer.class)到您的拓扑的配置。
这是我从我的一个组件中获得的示例
4:fetch __sendqueue {write_pos=12122, read_pos=12122, capacity=1024, population=0}
4:fetch __receive {write_pos=8588, read_pos=8587, capacity=1024, population=1}
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
