很简单的一个参数设置,但是在网上找了一圈,都没起到作用,可能是版本问题。

下面是我设置的参数,实践成功

轮询策略设置

partition.assignment.strategy=org.apache.kafka.clients.consumer.RoundRobinAssignor

范围策略设置

partition.assignment.strategy=org.apache.kafka.clients.consumer.RangeAssignor

简单来说就是要配置全路径类名,否则没用

更多推荐

Kafka分区策略参数设置partition.assignment.strategy