diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-12-10 17:48:05 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-12-10 18:37:03 -0800 |
| commit | 5cf60f4482852220efa5f727b45617ee3b7ad773 (patch) | |
| tree | 0d1da47070ea265324b2f783b7cc71a684793ea7 /test/test_protocol.py | |
| parent | 3662cb6c50f1a0f893cf23e18f4d14509b25dfa3 (diff) | |
| download | kafka-python-5cf60f4482852220efa5f727b45617ee3b7ad773.tar.gz | |
Remove KafkaProtocol._decode_message
Diffstat (limited to 'test/test_protocol.py')
| -rw-r--r-- | test/test_protocol.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/test/test_protocol.py b/test/test_protocol.py index 8cd4fee..7dfd44e 100644 --- a/test/test_protocol.py +++ b/test/test_protocol.py @@ -173,6 +173,7 @@ class TestProtocol(unittest.TestCase): self.assertEqual(encoded, expect) + @unittest.skip('needs updating for new protocol classes') def test_decode_message(self): encoded = b"".join([ struct.pack(">i", -1427009701), # CRC @@ -300,6 +301,7 @@ class TestProtocol(unittest.TestCase): self.assertEqual(returned_offset2, 0) self.assertEqual(decoded_message2, create_message(b"v2")) + @unittest.skip('needs updating for new protocol classes') def test_decode_message_checksum_error(self): invalid_encoded_message = b"This is not a valid encoded message" iter = KafkaProtocol._decode_message(invalid_encoded_message, 0) |