enable kafka static-partition-assignment (KIP-345) (#600)

Author: Mopsgeschwindigkeit

faust/transport/drivers/aiokafka.py

@@ -525,7 +525,7 @@ def _create_worker_consumer(
             api_version=conf.consumer_api_version,
             client_id=conf.broker_client_id,
             group_id=conf.id,
-            # group_instance_id=conf.consumer_group_instance_id,
+            group_instance_id=conf.consumer_group_instance_id,
             bootstrap_servers=server_list(transport.url, transport.default_port),
             partition_assignment_strategy=[self._assignor],
             enable_auto_commit=False,

tests/unit/transport/drivers/test_aiokafka.py

@@ -787,7 +787,7 @@ def assert_create_worker_consumer(
                 api_version=app.conf.consumer_api_version,
                 client_id=conf.broker_client_id,
                 group_id=conf.id,
-                # group_instance_id=conf.consumer_group_instance_id,
+                group_instance_id=conf.consumer_group_instance_id,
                 bootstrap_servers=server_list(transport.url, transport.default_port),
                 partition_assignment_strategy=[cthread._assignor],
                 enable_auto_commit=False,