Storm 的流量控制和多線程併發處理

面臨問題: storm多線程的時候,會遇到併發修改的問題,會報concurrentModificationException,以下圖所示 web 解決方法: 第一種治標不治本的方法: 一方面,對發送到kafka的數據進行控制,將線程sleep的時間變長網絡 if(count==18000) { try {
相關文章
相關標籤/搜索