我的拓扑结构如下所示:
喷口--->节流螺栓a--->螺栓b
螺栓a和b是基本螺栓,它们自动锚定和确认元组。
我试图通过在storm.yaml中添加以下配置来限制每秒通过拓扑发送的元组数:
topology.max.spout.pending:50个
螺栓a接收喷口发出的元组,并以每秒10元组的速率将它们发送给螺栓b。
但是,喷口不断发送大量元组,这些元组随后会失败,因为螺栓a在超时之前没有将它们发送到螺栓b,这反映在storm ui中:
在bolt b(id)确认之前,如何防止spout发出比topology.max.spout.pending更多的元组?
暂无答案!
目前还没有任何答案,快来回答吧!