17.5.5. 升级消费者和 Kafka Streams 应用程序以合作重新平衡

您可以升级 Kafka 用户和 Kafka Streams 应用程序，以使用 增量合作重新平衡 协议进行分区重新平衡，而不是默认的预先 重新平衡 协议。在 Kafka 2.4.0 中添加了新协议。

消费者将分区分配保持在合作重新平衡状态，并仅在流程结束时予以撤销（如果需要）来实现平衡集群。这可减少使用者组或 Kafka Streams 应用程序的不可用。

注意

升级到增量合作重新平衡协议是可选的。预先重新平衡协议仍然受到支持。

先决条件

流程

要升级 Kafka 消费者以使用增量合作重新平衡协议：

将 Kafka 客户端 .jar 文件替换为新版本。
在使用者配置中，将 cooperative-sticky 附加到 partition.assignment.strategy。例如，如果设置了 range 策略，请将配置改为 range, cooperative-sticky。
依次重新启动组中的每个使用者，等待使用者在每次重启后重新加入组。
通过从使用者配置中删除之前的 partition.assignment.strategy 策略来重新配置组中的每个消费者，只保留 cooperative-sticky 策略。
依次重新启动组中的每个使用者，等待使用者在每次重启后重新加入组。

升级 Kafka Streams 应用程序以使用增量合作重新平衡协议：

其它资源