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

15.5. 将消费者和 Kafka Streams 应用程序升级到合作重新平衡

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

消费者将分区分配保持在协作重新平衡中，并仅在需要实现均衡的集群时在进程结束时撤销它们。这可减少消费者组或 Kafka Streams 应用程序的不可用。

注意

升级到增量协作重新平衡协议是可选的。eager 重新平衡协议仍被支持。

先决条件

流程

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

  1. 将 Kafka 客户端 .jar 文件替换为新版本。
  2. 在消费者配置中，将 cooperative-sticky 附加到 partition.assignment.strategy。例如，如果设置了 范围 策略，请将配置更改为 range, cooperative-sticky。
  3. 依次重启组中的每个消费者，等待用户在每次重启后重新加入组。
  4. 通过从消费者配置中删除之前的 partition.assignment.strategy 来重新配置组中的每个消费者，仅保留 cooperative-sticky 策略。
  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

© 2025 Red Hat