diff options
Diffstat (limited to 'test/test_protocol.py')
| -rw-r--r-- | test/test_protocol.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/test/test_protocol.py b/test/test_protocol.py index f5bc289..ac7bea6 100644 --- a/test/test_protocol.py +++ b/test/test_protocol.py @@ -585,7 +585,7 @@ class TestProtocol(unittest.TestCase): results = KafkaProtocol.decode_consumer_metadata_response(encoded) self.assertEqual(results, - ConsumerMetadataResponse(error = 0, node = 1, host = b'brokers1.kafka.rdio.com', port = 1000) + ConsumerMetadataResponse(error = 0, nodeId = 1, host = b'brokers1.kafka.rdio.com', port = 1000) ) def test_encode_offset_request(self): |