日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

java学习笔记:Storm 常用配置

發布時間:2024/9/3 编程问答 34 豆豆
生活随笔 收集整理的這篇文章主要介紹了 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 常用配置的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。