Kafka分區策略及自定義

默認分區策略 默認分區策略是：取正（bytearray生成32位hash值）%numpartitions 這個公式的結果是獲得0-(numpartitions-1)間正整數的個數大體相等，也就是說kafka的默認分區策略是不管咱們給定多少個分區，咱們存放的數據基本上會平均的分到各個分區上。java private int defaultPartition(String topic, Object

>>阅读原文<<