summaryrefslogtreecommitdiff
path: root/test/test_consumer_group.py
Commit message (Expand)AuthorAgeFilesLines
* Convert remaining `KafkaConsumer` tests to `pytest` (#1886)Jeff Widman2019-08-221-0/+2
* Cleanup handling of KAFKA_VERSION env var in tests (#1887)Jeff Widman2019-08-221-10/+8
* Minor test cleanup (#1885)Jeff Widman2019-08-211-3/+2
* Sanity test for consumer.topics() and consumer.partitions_for_topic()Brian Sang2019-06-041-0/+9
* 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
* Vendor `six` consistentlyJeff Widman2018-10-221-1/+1
* 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
* 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
View Lorry Controller Status