summaryrefslogtreecommitdiff
path: root/test/test_protocol.py
Commit message (Collapse)AuthorAgeFilesLines
* Core Protocol: Add support for flexible versions (#2151)Tincu Gabriel2020-12-021-1/+53
| | | | | | | - Add support for new request and response headers, supporting flexible versions / tagged fields - Add List / Alter partition reassignments APIs - Add support for varints - Add support for compact collections (byte array, string, array)
* Minor test cleanup (#1885)Jeff Widman2019-08-211-1/+0
| | | | Remove unused import, whitespace, etc. No functional changes, just cleaning it up so the diffs of later changes are cleaner.
* Vendor `six` consistentlyJeff Widman2018-10-221-1/+1
| | | | Use vendored `six`, and also `six.moves.range` rather than `xrange`
* Refactor MessageSet and Message into LegacyRecordBatch to later support v2 ↵Taras2017-10-111-2/+3
| | | | message format
* Avoid re-encoding for message crc check (#1027)Dana Powers2017-03-131-0/+24
|
* Fix kwarg handing in kafka.protocol.struct.Struct (#1025)Dana Powers2017-03-091-1/+15
|
* Always encode size with MessageSet (#771)Dana Powers2016-07-171-2/+2
|
* Fix regression in MessageSet decoding wrt PartialMessages (#716)Dana Powers2016-06-011-1/+101
|
* Add some simple message protocol testsmessage_format_v1Dana Powers2016-05-221-0/+146
|
* Rename legacy protocol testsDana Powers2016-05-221-848/+0
|
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-10/+10
|
* Mark old kafka.common structs as Deprecated; remove unused TopicMetadataDana Powers2016-02-151-5/+8
|
* Rename TopicAndPartition -> TopicPartitionDana Powers2015-12-281-1/+1
|
* pylint fixesDana Powers2015-12-101-0/+1
| | | | | | - temporarily ignore kafka/consumer/group.py - temporarily ignore test/test_protocol.py - disable-msg deprecated; use disable= instead
* Remove KafkaProtocol._decode_messageDana Powers2015-12-101-0/+2
|
* Convert OffsetCommit and OffsetFetch protocol encode/decodeDana Powers2015-12-101-2/+2
|
* Update kafka.common imports to Payloads namedtuples in test_protocolDana Powers2015-12-091-22/+24
|
* Skip protocol tests for now -- need updatingDana Powers2015-12-091-0/+20
|
* Fix tests broken by legacy module moveDana Powers2015-12-041-3/+3
|
* Fix misnamed node to nodeId in testtpalino2015-07-021-1/+1
|
* Add missing import for ConsumerMetadataResponsetpalino2015-07-011-1/+1
|
* Support consumer metadata requeststpalino2015-07-011-0/+28
| | | | | | Support added for ConsumerMetadataRequest and ConsumerMetadataResponse Added consumer-aware request routine for supporting the consumer coordinator Added separate client method for fetching Kafka-committed offsets from the coordinator
* Correct message keys for async batching modeViktor Shlapakov2015-02-251-3/+63
|
* Use b''.join([]) instead of += to speedup codeDana Powers2014-09-101-18/+18
|
* Merge pull request #223 from dpkp/metadata_refactorDana Powers2014-09-081-40/+33
|\ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Metadata Refactor * add MetadataRequest and MetadataResponse namedtuples * add TopicMetadata namedtuple * add error codes to Topic and Partition Metadata * add KafkaClient.send_metadata_request() method * KafkaProtocol.decode_metadata_response changed to return a MetadataResponse object so that it is consistent with server api: [broker_list, topic_list] * raise server exceptions in load_metadata_for_topics(*topics) unless topics is null (full refresh) * Replace non-standard exceptions (LeaderUnavailable, PartitionUnavailable) with server standard exceptions (LeaderNotAvailableError, UnknownTopicOrPartitionError) Conflicts: kafka/client.py test/test_client.py test/test_producer_integration.py test/test_protocol.py
| * Use standard exceptions in client._get_leader_for_partition()Dana Powers2014-09-011-2/+2
| | | | | | | | | | | | - drop custom PartitionUnavailable exception - raise UnknownTopicOrPartitionError or LeaderNotAvailableError - add tests for exception raises
| * Improve metadata protocol handlingDana Powers2014-09-011-41/+33
| | | | | | | | | | | | | | | | | | | | - add MetadataRequest and MetadataResponse namedtuples - add TopicMetadata namedtuple - add error codes to Topic and Partition Metadata - add KafkaClient.send_metadata_request() method - KafkaProtocol.decode_metadata_response changed to return a MetadataResponse object so that it is consistent with server api: [broker_list, topic_list]
* | Merge pull request #227 from wizzat-feature/py3Dana Powers2014-09-071-184/+185
|\ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Python 3 Support Conflicts: kafka/producer.py test/test_client.py test/test_client_integration.py test/test_codec.py test/test_consumer.py test/test_consumer_integration.py test/test_failover_integration.py test/test_producer.py test/test_producer_integration.py test/test_protocol.py test/test_util.py
| * | Fix more tests, only multiprocessing consumer ones remainingBruno Renié2014-09-031-1/+0
| | |
| * | Make all unit tests pass on py3.3/3.4Bruno Renié2014-09-031-178/+179
| | |
| * | Use base unittest or unittest2 depending on python versionBruno Renié2014-09-031-4/+4
| |/
* | Cleanup tests: no more import *; remove unusedDana Powers2014-09-041-7/+2
| |
* | Import cleanups in testsDana Powers2014-09-041-9/+7
|/
* Improve error handling and tests w.r.t. codecsPatrick Lucas2014-05-071-6/+58
| | | | | | | | | | Add function kafka.protocol.create_message_set() that takes a list of payloads and a codec and returns a message set with the desired encoding. Introduce kafka.common.UnsupportedCodecError, raised if an unknown codec is specified. Include a test for the new function.
* Merge branch 'teach_producers_about_compression' into producer_compressionMark Roberts2014-05-071-5/+4
| | | | | | Conflicts: servers/0.8.0/kafka-src test/test_unit.py
* Fix Python 2.6 supportMark Roberts2014-04-231-10/+10
|
* Split out kafka version environments, default tox no longer runs any ↵Mark Roberts2014-04-231-3/+1
| | | | integration tests, make skipped integration also skip setupClass, implement rudimentary offset support in consumer.py
* Add final tests for 100% coverage of protocol.py from test/test_protocol.pyMark Roberts2014-04-091-6/+63
|
* Add encode_offset_fetch_request testMark Roberts2014-04-091-9/+40
|
* Add commit offset request testMark Roberts2014-04-091-26/+47
|
* Add tests for encode_offset_requestMark Roberts2014-04-091-3/+43
|
* Add python-snappy to tox dependencies. Fix snappy protocol testMark Roberts2014-04-091-27/+36
|
* Convert test_encode_fetch_request to struct.pack format, improve test ↵Mark Roberts2014-04-091-12/+45
| | | | reliability
* Update more tests, fix intermittent failureMark Roberts2014-04-091-40/+89
|
* Convert more tests to struct.packMark Roberts2014-04-081-29/+75
|
* Convert serveral tests to struct.packMark Roberts2014-04-081-81/+93
|
* Reinstate test_integrate, make test_protocol more explicit, create testutilMark Roberts2014-04-081-5/+28
|
* Explicit testing of protocol errors. Make tests more explicit, and start ↵Mark Roberts2014-04-081-13/+34
| | | | working on intermittent failures in test_encode_fetch_request and test_encode_produc_request
* Split test files, modify test_protocolMark Roberts2014-04-081-0/+354
View Lorry Controller Status