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