From 12c9600e3c7b8e5f65efe104a1b9ee82ca42dcc3 Mon Sep 17 00:00:00 2001
From: Peter Olson <polson@domaintools.com>
Date: Wed, 12 Feb 2025 09:35:36 -0800
Subject: [PATCH] Also use faust rebalance protocol when using static parition
 assignment

---
 faust/transport/drivers/aiokafka.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/faust/transport/drivers/aiokafka.py b/faust/transport/drivers/aiokafka.py
index 8da59e5f6..b3e033e98 100644
--- a/faust/transport/drivers/aiokafka.py
+++ b/faust/transport/drivers/aiokafka.py
@@ -511,6 +511,7 @@ def _create_worker_consumer(
         self._assignor = (
             self.app.assignor
             if self.app.conf.table_standby_replicas > 0
+            or self.app.conf.consumer_group_instance_id
             else RoundRobinPartitionAssignor
         )
         auth_settings = credentials_to_aiokafka_auth(