很简单的一个参数设置,但是在网上找了一圈,都没起到作用,可能是版本问题。
下面是我设置的参数,实践成功
轮询策略设置
partition.assignment.strategy=org.apache.kafka.clients.consumer.RoundRobinAssignor
范围策略设置
partition.assignment.strategy=org.apache.kafka.clients.consumer.RangeAssignor
简单来说就是要配置全路径类名,否则没用
更多推荐
Kafka分区策略参数设置partition.assignment.strategy
发布评论