设为首页 加入收藏

TOP

kafka默认消息分片路由规则
2019-01-21 02:35:13 】 浏览:42
Tags:kafka 默认 消息 分片 路由 规则

发一个消息,如何知道消息被默认分片到哪里

1.如果没有指定key,是随机分片

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

可以套用一下公式计算:

key.hashCode() % 12

例如有一个topic 叫test,有8个patition,key="1",则日志文件在

"1".hashCode() % 8=1

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

】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇Kafka's Metadata In ZooKeep.. 下一篇Kafka源码之KafkaProducer分析

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目