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(