[kafka扫盲]---(6)kafka源码阅读之分区器

Author：赵志乾 Date：2018-10-21 Declaration：All Right Reserved！！！ DefaultPartitioner.javajava 该类实现了Partitioner接口，核心方法为partition()：用于给未指定分区号的消息记录生成分区号，其生成策略也比较简单。其依据是否指定key值采用两种不一样的策略：若是指定key值，则按照key的hash来生

>>阅读原文<<