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

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