diff --git a/test/test_coordinator.py b/test/test_coordinator.py index 88ca4c1fc..ea8f84bb6 100644 --- a/test/test_coordinator.py +++ b/test/test_coordinator.py @@ -55,7 +55,7 @@ def test_autocommit_enable_api_version(client, api_version): def test_protocol_type(coordinator): - assert coordinator.protocol_type() is 'consumer' + assert coordinator.protocol_type() == 'consumer' def test_group_protocols(coordinator):