kafka中topic的partition数量和customerGroup的customer数量关系以及storm消费kafka时并行度设置问题总结:

前段时间经过网上查找和本身测试仔细研究了partition和customer关系以及工做中遇到的storm并行度调整的问题,认真梳理了一下现总结以下:html 1、先说kafka部分:node produce方面:并发 若是有多个分区,发送的时候按照key值hashCode%partitionNum哈希取模分区数来决定该条信息发往哪一个partition, 这里能够自定义partition的分发策
相关文章
相关标签/搜索