admin管理员组

文章数量:1572796

轮询策略设置

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

范围策略设置

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

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

本文标签: 分区参数设置策略KafkaAssignment