summaryrefslogtreecommitdiff
path: root/test/test_consumer_group.py
Commit message (Collapse)AuthorAgeFilesLines
* Use test.fixtures.version not test.conftest.version to avoid warnings (#1731)Dana Powers2019-03-061-2/+1
|
* Migrate from `Unittest` to `pytest` (#1620)Jeff Widman2018-11-101-18/+2
|
* Cleanup fixture importsJeff Widman2018-10-271-1/+1
| | | | | | | | | | | | | | | `random_string` now comes from `test.fixtures` and was being transparently imported via `test.testutil` so this bypasses the pointless indirect import. Similarly, `kafka_version` was transparently imported by `test.testutil` from `test.fixtures`. Also removed `random_port()` in `test.testutil` because its unused as its been replaced by the one in `test.fixtures`. This is part of the pytest migration that was started back in a1869c4be5f47b4f6433610249aaf29af4ec95e5.
* Vendor `six` consistentlyJeff Widman2018-10-221-1/+1
| | | | Use vendored `six`, and also `six.moves.range` rather than `xrange`
* Close KafkaConsumer instances during tests (#1410)Dana Powers2018-03-081-0/+3
|
* Minor test cleanups (#1343)Dana Powers2018-01-121-2/+3
|
* KAFKA-3888 Use background thread to process consumer heartbeats (#1266)Dana Powers2017-12-211-3/+42
|
* Use fixture hostname (dont assume localhost)Dana Powers2017-06-181-1/+1
|
* Disable default consumer group (#1016)Dana Powers2017-03-061-0/+2
|
* KAFKA-3007: KafkaConsumer max_poll_records (#831)Dana Powers2016-09-281-8/+0
|
* Change coordinator.needs_join_prepare -> coordinator.rejoining; fix consumer ↵Dana Powers2016-08-041-1/+6
| | | | group test (#795)
* Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)Dana Powers2016-07-161-1/+1
|
* Improve consumer group test loopDana Powers2016-05-221-13/+13
|
* Consolidate conn fixture definitionsDana Powers2016-04-071-14/+0
|
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-051-1/+1
|
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-1/+1
|
* KAFKA-2698: add paused APIZack Dever2016-03-161-5/+25
|
* join consumer threads in test_consumer_group cleanupDana Powers2016-03-141-2/+4
|
* Add heartbeat timeout testDana Powers2016-03-121-3/+24
|
* Make sure all consumers are in same generation before stopping group testDana Powers2016-02-161-0/+13
|
* Remove test_correlation_id_rollover; use daemon threads for test consumersDana Powers2016-01-251-44/+3
|
* Move pytest broker/zk fixtures to test.conftestDana Powers2016-01-241-29/+1
|
* Log generation and member_id in threaded consumer group testDana Powers2016-01-101-1/+4
|
* Fix KafkaClient->SimpleClient references0.9Dana Powers2016-01-071-2/+2
|
* Drop request_timeout_ms override in consumer group testDana Powers2016-01-041-2/+1
|
* Fast heartbeats during consumer group testsDana Powers2016-01-031-0/+1
|
* Add pytests for KafkaConsumer group assignmentsDana Powers2016-01-031-0/+170