kafka中topic的partition數量和customerGroup的customer數量關係以及storm消費kafka時並行度設置問題總結:

前段時間通過網上查找和自己測試仔細研究了partition和customer關係以及工作中遇到的storm並行度調整的問題,認真梳理了一下現總結如下: 一、先說kafka部分: produce方面: 如果有多個分區,發送的時候按照key值hashCode%partitionNum哈希取模分區數來決定該條信息發往哪個partition, 這裏可以自定義partition的分發策略,只要實現Parti
相關文章
相關標籤/搜索