Red Hat Summit 红帽全球峰会支持控制台（Console）开发人员开始试用联系人

9.6. 将消费者升级到合作重新平衡

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

消费者将其分区分配保持在相互平衡中，只有在需要达到均衡的集群，仅在进程结束时撤销它们。这可减少消费者组或 Kafka Streams 应用程序不可用。

注意

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

先决条件

流程

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

  1. 将 Kafka 客户端 .jar 文件替换为新版本。
  2. 在消费者配置中，将 c partnership-sticky 附加到 分区.assignment.strategy。例如，如果设置了 范围 策略，请将配置更改为 范围，合作-sticky。
  3. 依次重新启动组中的每个消费者，等待使用者在每次重启后重新加入该组。
  4. 通过从消费者配置中删除之前 的分区.assignment.strategy 来重新配置组中的每个消费者，仅让合作策略 成为一个合作 策略。
  5. 依次重新启动组中的每个消费者，等待使用者在每次重启后重新加入该组。

要升级 Kafka Streams 应用程序，请使用增量重新平衡协议：

  1. 将 Kafka Streams .jar 文件替换为新版本。
  2. 在 Kafka Streams 配置中，将 upgrade.from 配置参数设置为您要从升级的 Kafka 版本（如 2.3）。
  3. 依次重启每个流处理器（节点）。
  4. 从 Kafka Streams 配置中删除 upgrade.from 配置参数。
  5. 依次重新启动组中的每个消费者。
返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务，以及可以信赖的内容，帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情，请参阅红帽博客.

關於紅帽

我们提供强化的解决方案，使企业能够更轻松地跨平台和环境（从核心数据中心到网络边缘）工作。

Theme

© 2026 Red Hat