https://blog.csdn.net/j3T9Z7H/article/details/112255601
1、生产者
org.apache.kafka.clients.producer.internals.DefaultPartitioner
(1)默认的分区策略是:
- 如果在发消息的时候指定了分区,则消息投递到指定的分区
- 如果没有指定分区,但是消息的key不为空,则基于key的哈希值来选择一个分区
- 如果既没有指定分区,且消息的key也是空,则用轮询的方式选择一个分区
(2)自定义分区策略
https://blog.csdn.net/lishuangzhe7047/article/details/73188618?utm_source=blogxgwz9
2、消费者
(1)range:基于每个topic的分区策略。
(2)roundrobin(轮询):基于所有topic的分区策略。
(3)自定义