springboot2.x +kafka使用和源碼分析八(自定義分區器)

1:DefaultPartitioner默認分區器 若是producer沒指定落地到指定partition中，Kafak經過默認的分區器對數據進行partition，默認的分區的規則是對key進行hash取值 % 分區數, 相同的key會分佈到同一分區中。若是沒指定key，則就按照輪詢算法將消息均勻的分佈在主題的可用分區上。java /** * * 自定義分區器 */ public clas

>>阅读原文<<