summaryrefslogtreecommitdiff
path: root/test/test_consumer_group.py
Commit message (Expand)AuthorAgeFilesLines
* 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