diff options
| author | tpalino <tpalino@linkedin.com> | 2015-07-02 09:32:37 -0700 |
|---|---|---|
| committer | tpalino <tpalino@linkedin.com> | 2015-07-02 09:32:37 -0700 |
| commit | da03827d12520bd9c8c5b35bb43e35168f09771a (patch) | |
| tree | 4f6c657213c1027accd65167e5c68271efc93343 /test/test_protocol.py | |
| parent | 5d8d5412e576c5514497be3809ea899378f40e56 (diff) | |
| download | kafka-python-da03827d12520bd9c8c5b35bb43e35168f09771a.tar.gz | |
Fix misnamed node to nodeId in test
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): |