首页
技术小册
AIGC
面试刷题
技术文章
MAGENTO
云计算
视频课程
源码下载
PDF书籍
「涨薪秘籍」
登录
注册
Kafka简介
Kafka工作流程
Kafka存储机制
Kafka分区机制
Kafka生产者与消费者
Kafka ack机制
安装Kafka
Producer消息缓存模型
指定副本作为Leader
Kafka的ISR伸缩机制
acks和mir配置详解
Kafka主动修改分区Leader
Kafka向Server发起请求
当前位置:
首页>>
技术小册>>
kafka入门到实战
小册名称：kafka入门到实战
分区原因： ⽅便在集群中扩展，每个 Partition 可以通过调整以适应它所在的机器，⽽⼀个 Topic ⼜可以有多个 Partition 组成，因此可以以 Partition 为单位读写了。 可以提⾼并发，避免两个分区持久化的时候争夺资源。 备份的问题。防止一台机器宕机后数据丢失的问题。 分区原则：我们需要将 Producer 发送的数据封装成⼀个 ProducerRecord 对象。该对象需要指定⼀些参数： - topic：string 类型，NotNull。 - partition：int 类型，可选。 - timestamp：long 类型，可选。 - key：string 类型，可选。 - value：string 类型，可选。 - headers：array 类型，Nullable。 指明 Partition 的情况下，直接将给定的 Value 作为 Partition 的值；没有指明 Partition 但有 Key 的情况下，将 Key 的 Hash 值与分区数取余得到 Partition 值；既没有 Partition 又没有 Key 的情况下，第⼀次调⽤时随机⽣成⼀个整数（后⾯每次调⽤都在这个整数上⾃增），将这个值与可⽤的分区数取余，得到 Partition 值，也就是常说的 Round-Robin轮询算法。
上一篇：
Kafka存储机制
下一篇：
Kafka生产者与消费者
该分类下的相关小册推荐：
Kafka面试指南
Kafka 原理与源码精讲
Kafka核心源码解读
消息队列入门与进阶
Kafka核心技术与实战
