kafkakafka 2.4 static membership功能 group.instance.id

Posted 2022-01-27 九师兄

1.概述

首先参考文章：【kafka】Kafka消费者分区分配策略详解

2.官网

地址：Static Membership

静态成员关系旨在提高流应用程序、消费者组和其他构建在组再平衡协议之上的应用程序的可用性。rebalance协议依赖于组协调器为组成员分配实体id。这些生成的id是短暂的，当成员重新启动和重新加入时将会改变。对于基于消费者的应用程序，这种“动态成员”可能会导致在代码部署、配置更新和定期重启等管理操作期间，将大量任务重新分配给不同的实例。对于大型状态应用程序，在处理前，打乱的任务需要很长时间来恢复其本地状态，从而导致应用程序部分或完全不可用。基于这种观察，Kafka的组管理协议允许组成员提供持久的实体id。基于这些id，组成员保持不变，因此不会触发再平衡。

如果要使用静态成员资格，

• 将代理集群和客户端应用程序升级到 2.3 或更高版本，并确保升级后的代理也使用inter.broker.protocol.vers