同一机器启动多个Kafka Streams应用触发Cooperative重平衡报错

这个java.lang.IllegalStateException: Assignor supporting the COOPERATIVE protocol violates its requirements报错是Kafka消费者层的协议校验失败触发的，核心原因是同一个消费者组（对应Kafka Streams的application.id配置）下同时存在使用不同重平衡协议的客户端，或者分区分配结果违反了Cooperative协议的基本要求。
你配置独立state.dir无法解决问题，因为该问题属于消费者组重平衡协议层面的错误，和本地状态存储路径配置无关。

• 首先校验所有属于同一个application.id的Streams实例的partition.assignment.strategy配置完全统一：
  不能出现部分实例配置org.apache.kafka.clients.consumer.CooperativeStickyAssignor，其他实例配置StickyAssignor、RangeAssignor等Eager协议分配器的情况，混合协议会直接触发该校验报错。
• 如果你是从2.7及更早版本的Kafka Streams升级到2.8+版本（2.8开始Streams默认使用CooperativeStickyAssignor），必须走双阶段滚动升级流程：
  1. 先给所有实例的分配器配置为org.apache.kafka.clients.consumer.CooperativeStickyAssignor,org.apache.kafka.clients.consumer.StickyAssignor，滚动重启全部实例
  2. 再把所有实例的分配器配置改为仅保留org.apache.kafka.clients.consumer.CooperativeStickyAssignor，第二次滚动重启全部实例，避免升级过程中出现协议混合。
• 确认你启动的两个实例的业务身份：如果是同一应用的扩容节点，必须保证application.id完全一致；如果是两个独立的业务应用，必须配置不同的application.id，避免无关应用加入同一个消费者组触发协议冲突。
• 如果你自定义了分区分配器，需要检查分配逻辑是否符合Cooperative协议要求：不能出现同一个分区被分配给多个消费者实例的情况，该报错的校验逻辑就是检测到分配结果违反了该要求才抛出的。

如果你用原生消费者客户端配置CooperativeStickyAssignor时遇到相同报错，排查逻辑完全一致，保证同消费组下所有消费者的分区分配器配置统一即可。

内容的提问来源于stack exchange，提问作者jaivalis