summaryrefslogtreecommitdiff
path: root/test/test_consumer.py
Commit message (Collapse)AuthorAgeFilesLines
* Remove SimpleClient, Producer, Consumer, Unittest (#1196)Jeff Widman2019-10-111-133/+2
| | | | | | | | | | | | | | | | | | 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`.
* Error if connections_max_idle_ms not larger than request_timeout_ms (#1688)Jeff Widman2019-03-141-2/+6
|
* Migrate from `Unittest` to `pytest` (#1620)Jeff Widman2018-11-101-7/+9
|
* KAFKA-3888 Use background thread to process consumer heartbeats (#1266)Dana Powers2017-12-211-2/+2
|
* Return copy of consumer subscription set (#1029)Dana Powers2017-03-131-0/+8
|
* Fail-fast on timeout constraint violations during KafkaConsumer creation (#986)Harel Ben-Attia2017-02-281-0/+8
|
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-5/+5
|
* Skip test that fails on windowswindowsDana Powers2016-03-171-0/+2
|
* bootstrap_servers no longer required in KafkaConsumer (localhost default)Dana Powers2016-01-031-4/+0
|
* Convert OffsetCommit and OffsetFetch protocol encode/decodeDana Powers2015-12-101-2/+2
|
* Fix test_consumer generator/list mock, reenable testsDana Powers2015-12-101-5/+2
|
* Update to Payload namedtuples in consumer testsDana Powers2015-12-091-4/+4
|
* Skip consumer tests that cause iterator errors -- needs investigationDana Powers2015-12-091-0/+3
|
* (test) SimpleConsumer.reset_partition_offset should not raise exception on ↵Dana Powers2015-06-101-1/+16
| | | | failure
* (test) Consumer commit() should log errors and return True/False, not raise ↵Dana Powers2015-06-101-0/+24
| | | | exceptions
* Split consumer test class between Simple and MultiProcessDana Powers2015-06-101-1/+2
|
* Add unit tests for SimpleConsumer error handlingDana Powers2015-06-081-1/+74
|
* Support optional partitions kwarg in MultiProcessConsumerDana Powers2015-05-171-2/+11
|
* Move KafkaConsumer to kafka.consumer.kafka module; make available for import ↵Dana Powers2014-12-151-2/+1
| | | | from kafka at top-level
* Add a few basic KafkaConsumer testsDana Powers2014-12-151-0/+6
|
* Merge pull request #227 from wizzat-feature/py3Dana Powers2014-09-071-2/+2
|\ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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
| * Use base unittest or unittest2 depending on python versionBruno Renié2014-09-031-2/+2
| |
* | Cleanup tests: no more import *; remove unusedDana Powers2014-09-041-14/+2
|/
* Various fixesMark Roberts2014-04-251-0/+22
Bump version number to 0.9.1 Update readme to show supported Kafka/Python versions Validate arguments in consumer.py, add initial consumer unit test Make service kill() child processes when startup fails Add tests for util.py, fix Python 2.6 specific bug.