我被风暴用户界面的统计数据搞糊涂了。
例如：
拓扑统计显示有6900万
Kafka喷口显示了3400万个数字
__阿克有1700万
博尔特也有1700万
我的主题是Kafka喷口-->es博尔特，我不知道上面的数字是怎么加起来的？
如果Kafka喷口的排放量只有3400万，为什么拓扑统计显示有6900万？
再说一次，如果Kafka喷口排放了3400万，为什么es博尔特说1700万？
我看到了元组从上到下被减半的模式，但我不知道为什么？是因为ack元组还是心跳螺栓？
它们总是上游喷口的一半吗？
我被风暴用户界面的统计数据搞糊涂了。
例如：
拓扑统计显示有6900万
Kafka喷口显示了3400万个数字
__阿克有1700万
博尔特也有1700万
我的主题是Kafka喷口-->es博尔特，我不知道上面的数字是怎么加起来的？
如果Kafka喷口的排放量只有3400万，为什么拓扑统计显示有6900万？
再说一次，如果Kafka喷口排放了3400万，为什么es博尔特说1700万？
我看到了元组从上到下被减半的模式，但我不知道为什么？是因为ack元组还是心跳螺栓？
它们总是上游喷口的一半吗？
3条答案
按热度按时间mf98qq941#
请记住，这些度量是以topology.stats.sample.rate的速率o进行采样的，默认值为0.05。如果你把它调高到1.0，你会看到完整的解决方案，尽管代价是花费更多的时间收集指标。
polkgigr2#
拓扑统计显示有6900万个，这是你所有的喷口和螺栓的总和：34.x+17.x+17.x
喷口和螺栓的发射数并没有必然的联系。这和你的代码有关。
zed5wv103#
你可以关闭系统统计，那么数字就有意义了。在storm ui统计页面的底部有一个按钮。