diff --git a/faust/transport/drivers/aiokafka.py b/faust/transport/drivers/aiokafka.py
index 8a17c1c7b..70bd967be 100644
--- a/faust/transport/drivers/aiokafka.py
+++ b/faust/transport/drivers/aiokafka.py
@@ -578,7 +578,9 @@ def _create_worker_consumer(
         has_changelog_tables = bool(self.app.tables.changelog_topics)
         self._assignor = (
             self.app.assignor
-            if self.app.conf.table_standby_replicas > 0 or has_changelog_tables
+            if self.app.conf.table_standby_replicas > 0
+            or self.app.conf.consumer_group_instance_id
+            or has_changelog_tables
             else RoundRobinPartitionAssignor
         )
         auth_settings = credentials_to_aiokafka_auth(