kafka的分区分配策略

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)自定义

原文地址:https://www.cnblogs.com/guoyu1/p/14285211.html