6.3. 将合作重新平衡与消费者一起使用

流程

1. 在消费者配置中，使用 partition.assignment.strategy 属性切换到使用 CooperativeStickyAssignor 作为协议。例如，如果当前配置是 partition.assignment.strategy=RangeAssignor, CooperativeStickyAssignor，请将其更新为 partition.assignment.strategy=CooperativeStickyAssignor。

   您还可以使用消费者应用程序代码中的 props.put 设置分区分配策略，而不是直接修改消费者配置文件：

   # ...
   props.put(ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG, "org.apache.kafka.clients.consumer.CooperativeStickyAssignor");
   # ...

   Copy to Clipboard
2. 一次重启组中的每个消费者，允许它们在每次重启后重新加入组。