summaryrefslogtreecommitdiff
path: root/test/test_client.py
Commit message (Collapse)AuthorAgeFilesLines
* Remove SimpleClient, Producer, Consumer, Unittest (#1196)Jeff Widman2019-10-111-405/+0
| | | | | | | | | | | | | | | | | | In the 2.0 release, we're removing: * `SimpleClient` * `SimpleConsumer` * `SimpleProducer` * Old partitioners used by `SimpleProducer`; these are superceded by the `DefaultPartitioner` These have been deprecated for several years in favor of `KafkaClient` / `KafkaConsumer` / `KafkaProducer`. Since 2.0 allows breaking changes, we are removing the deprecated classes. Additionally, since the only usage of `unittest` was in tests for these old Simple* clients, this also drops `unittest` from the library. All tests now run under `pytest`.
* Vendor `six` consistentlyJeff Widman2018-10-221-1/+1
| | | | Use vendored `six`, and also `six.moves.range` rather than `xrange`
* Stop shadowing `ConnectionError`Jeff Widman2018-05-231-1/+1
| | | | | | | | | | In Python3, `ConnectionError` is a native exception. So rename our custom one to `KafkaConnectionError` to prevent accidentally shadowing the native one. Note that there are still valid uses of `ConnectionError` in this code. They already expect a native Python3 `ConnectionError`, and also already handle the Python2 compatibility issues.
* Move callback processing from BrokerConnection to KafkaClientpending_completionsDana Powers2017-10-151-1/+2
|
* Stop using mutable types for default arg values1212-stop-using-mutable-types-for-default-arg-valuesJeff Widman2017-09-121-1/+1
| | | | | | | | Using mutable types for default args is typically a no-no unless their surprising behavior is being explicitly abused, for an explanation see: http://effbot.org/zone/default-values.htm Fix #1212
* Add rack to BrokerMetadata - it is always None when using MetadataRequest v0Dana Powers2016-07-161-26/+35
|
* Rearrange connection tests to separate legacy KafkaConnectionDana Powers2016-06-041-18/+1
|
* More thorough IPv6 support that uses getaddrinfo to resolve namesJames Brown2016-04-241-3/+6
| | | | Fixes #641
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-051-10/+10
|
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-7/+4
|
* Kafka IPv6 Support.Tim Evens2016-03-301-5/+6
| | | | | | IPv6 address without port can be defined as the IPv6 address. If the address is a hostname or if a port is included, then the address MUST be wrapped in brackets [] (E.g. [somehost]:1234 or [fd00:1001::2]:1234).
* catch all errors thrown by _get_leader_for_partition in SimpleClientZack Dever2016-03-171-3/+3
|
* Fix KafkaClient->SimpleClient references0.9Dana Powers2016-01-071-32/+32
|
* Rename TopicAndPartition -> TopicPartitionDana Powers2015-12-281-10/+10
|
* Switch BrokerConnection to (mostly) non-blocking IO.Dana Powers2015-12-171-35/+47
| | | | | | - return kafka.Future on send() - recv is now non-blocking call that completes futures when possible - update KafkaClient to block on future completion
* Drop kafka_bytestringDana Powers2015-12-101-9/+8
|
* Update client tests for new protocol usageDana Powers2015-12-091-74/+61
|
* Make external API consistently support python3 strings for topic.Space2015-04-031-34/+36
|
* Add test for correlation_id rolloverDana Powers2015-03-291-0/+8
|
* Use reflection to avoid multiple errno definitionsAlex Couture-Beil2015-01-101-3/+2
|
* Merge pull request #223 from dpkp/metadata_refactorDana Powers2014-09-081-79/+218
|\ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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
| * Add client unit tests for has_metadata_for_topic and ensure_topic_existsDana Powers2014-09-011-1/+63
| |
| * Add test for sending produce request to unknown topic w/o auto-creationDana Powers2014-09-011-0/+25
| |
| * Use standard exceptions in client._get_leader_for_partition()Dana Powers2014-09-011-8/+18
| | | | | | | | | | | | - drop custom PartitionUnavailable exception - raise UnknownTopicOrPartitionError or LeaderNotAvailableError - add tests for exception raises
| * load_metadata_for_topics should raise exceptions on explicit topic argsDana Powers2014-09-011-25/+46
| |
| * No more custom LeaderUnavailableError exception -- raise LeaderNotAvailableErrorDana Powers2014-09-011-2/+2
| |
| * Improve metadata protocol handlingDana Powers2014-09-011-68/+90
| | | | | | | | | | | | | | | | | | | | - 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-16/+19
|\ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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 test errors related to mocksMark Roberts2014-09-031-3/+6
| | |
| * | Make all unit tests pass on py3.3/3.4Bruno Renié2014-09-031-10/+11
| | |
| * | Use base unittest or unittest2 depending on python versionBruno Renié2014-09-031-2/+2
| |/
* | Fix socket timeout test -- mock the side_effectDana Powers2014-09-011-1/+19
|/
* Add pylint to tox.ini; test both kafka and test; default to error-checking ↵Dana Powers2014-08-251-6/+1
| | | | only; fixup errors; skip kafka/queue.py
* Fix Python 2.6 supportMark Roberts2014-04-231-2/+2
|
* Refactor away _get_conn_for_broker. Fix bug in _get_connMark Roberts2014-04-091-1/+1
|
* Split test files, modify test_protocolMark Roberts2014-04-081-15/+237
|
* Remove test support for py26 since it's brokenMark Roberts2014-04-071-0/+27
View Lorry Controller Status