kafka 允许通过配置 partition.assignment.strategy 来改变消费组的分区策略。kafka 提供了以下几个分区策略 RangeAssignor RoundRobinAssignor StickyAssignor 默认使用的是 RangeAssignor 同时,kafka 也允许我们自定义分区策略,只需要继承 AbstractPartitionAssignor 抽象类即可。 1、RangeAssignor 现假设有消费组 c1, c2,均订阅 t0, t1, 每个 topic 下均有 2…