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/ 目录下面
相关推荐
sweetgirl0 2020-06-28
Lzs 2020-10-23
聚合室 2020-11-16
零 2020-09-18
Justhavefun 2020-10-22
jacktangj 2020-10-14
ChaITSimpleLove 2020-10-06
Andrea0 2020-09-18
周游列国之仕子 2020-09-15
afanti 2020-09-16
88234852 2020-09-15
YClimb 2020-09-15
风雨断肠人 2020-09-04
卖口粥湛蓝的天空 2020-09-15
stulen 2020-09-15
pythonxuexi 2020-09-06
abfdada 2020-08-26