什么是分区分配策略
通過前面的案例演示,我們應該能猜到,同一個group中的消費者對于一個topic中的多個partition,存在一定的分區分配策略。
在kafka中,存在三種分區分配策略,一種是Range(默認)、 另一種是RoundRobin(輪詢)、StickyAssignor(粘性)。 在消費端中的ConsumerConfig中,通過這個屬性來指定分區分配策略
public static final String PARTITION_ASSIGNMENT_STRATEGY_CONFIG = "partition.assignment.strategy";?
總結
- 上一篇: 【思考?】什么时候会触发这个策略呢?
- 下一篇: 如何保存消费端的消费位置