什麼是分割槽分配策略
阿新 • • 發佈:2021-01-27
通過前面的案例演示,我們應該能猜到,同一個group中的消費者對於一個topic中的多個partition,存在一定的分割槽分配策略。
在kafka中,存在三種分割槽分配策略,一種是Range(預設)、 另一種是RoundRobin(輪詢)、StickyAssignor(粘性)。 在消費端中的ConsumerConfig中,通過這個屬性來指定分割槽分配策略
public static final String PARTITION_ASSIGNMENT_STRATEGY_CONFIG =
"partition.assignment.strategy";