kafka默認消息分片路由規則

 發一個消息，如何知道消息被默認分片到哪里

1.如果沒有指定key,是隨機分片

2.如果指定了key，即  new KeyedMessage<String, String>(String topic, String key, String message)

 

可以套用一下公式計算:

          key.hashCode() % 12

 

例如有一個topic 叫test,有8個patition,key="1"，則日志文件在

        "1".hashCode() % 8=1

在 *****/log/test-1/    目錄下面

 

ref: https://www.iteye.com/blog/dashiliu-2416073