java学习笔记:Storm 常用配置
生活随笔
收集整理的這篇文章主要介紹了
java学习笔记:Storm 常用配置
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
1)Config.TOPOLOGY_WORKERS:
這個設置用多少個工作進程來執行這個 topology。比如,如果你把它設置成 25,那么集群里面一共會有25個java進程來執行這個topology 的所有task。如果你的這個 topology 里面所有組件加起來一共有150的并行度,那么每個進程里面會有6個線程(150/ 25=6)。
2)Config.TOPOLOGY_ACKERS:
這個配置設置 acker 任務的并行度。默認的 acker 任務并行度為1,當系統中有大量的消息時,應該適當提高 acker 任務的并發度。設置為0,通過此方法,當 Spout 發送一個消息的時候,它的ack方法將立刻被調用;
3)Config.TOPOLOGY_MAX_SPOUT_PENDING:
這個設置一個 spout task 上面最多有多少個沒有處理的 tuple(沒有ack/failed)回復, 我們推薦你設置這個配置,以防止 tuple 隊列爆掉。
4)Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS:
這個配置storm 的tuple的超時時間–超過這個時間的tuple被認為處理失敗了。這個設置的默認設置是30秒
總結
以上是生活随笔為你收集整理的java学习笔记:Storm 常用配置的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 学习Java软件开发该从何入手
- 下一篇: 别再说PHP已死了,它活得好着呢