Kafka分区策略及自定义

默认分区策略 默认分区策略是：取正（bytearray生成32位hash值）%numpartitions 这个公式的结果是获得0-(numpartitions-1)间正整数的个数大体相等，也就是说kafka的默认分区策略是不管咱们给定多少个分区，咱们存放的数据基本上会平均的分到各个分区上。java private int defaultPartition(String topic, Object

>>阅读原文<<