apache storm:max.spout.pending未按预期工作

bttbmeg0  于 2021-06-24  发布在  Storm
关注(0)|答案(0)|浏览(216)

我的拓扑结构如下所示:
喷口--->节流螺栓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更多的元组?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题