[kafka掃盲]---(6)kafka源碼閱讀之分區器

Author:趙志乾 Date:2018-10-21 Declaration:All Right Reserved!!! DefaultPartitioner.javajava 該類實現了Partitioner接口,核心方法爲partition():用於給未指定分區號的消息記錄生成分區號,其生成策略也比較簡單。其依據是否指定key值採用兩種不一樣的策略:若是指定key值,則按照key的hash來生
相關文章
相關標籤/搜索