Storm 反壓機制 back pressure設置失效

topology.max.spout.pending 的意義在於 ,緩存spout 發送出去的tuple,當下流的bolt還有topology.max.spout.pending 個 tuple 沒有消費完時,spout會停下來,等待下游bolt去消費,當tuple 的個數少於topology.max.spout.pending個數時,spout 會繼續從消息源讀取消息。(這個屬性只對可靠消息處理
相關文章
相關標籤/搜索