summaryrefslogtreecommitdiff
path: root/test/test_coordinator.py
Commit message (Collapse)AuthorAgeFilesLines
* Don't use `kafka.common` internally1.3.5Jeff Widman2018-06-051-3/+3
| | | | This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`.
* KAFKA-3949: Avoid race condition when subscription changes during rebalance ↵Dana Powers2018-02-021-37/+21
| | | | (#1364)
* Minor test cleanups (#1343)Dana Powers2018-01-121-0/+1
|
* Fix coordinator join_future race condition (#1338)Dana Powers2018-01-111-0/+13
| | | * Fix race condition in coordinator join_future handling
* KAFKA-3888 Use background thread to process consumer heartbeats (#1266)Dana Powers2017-12-211-39/+61
|
* Handle lookup_coordinator send failures (#1279)Dana Powers2017-10-241-0/+8
|
* KAFKA-4034: Avoid unnecessary consumer coordinator lookup (#1254)Dana Powers2017-10-111-5/+4
|
* Treat metric_group_prefix as config in KafkaConsumerDana Powers2016-08-041-4/+3
|
* KAFKA-3486: fix autocommit when partitions assigned manually (#767 / #626)Dana Powers2016-07-171-5/+0
|
* KAFKA-3117: handle metadata updates during consumer rebalance (#766 / #701)Dana Powers2016-07-171-1/+1
|
* Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)Dana Powers2016-07-161-13/+14
|
* Include zk-offset configuration in coordinator unit testsDana Powers2016-07-161-2/+6
|
* Fix KafkaConsumer autocommit for 0.8 brokers (#756 / #706)Dana Powers2016-07-161-3/+2
| | | | * Dont wait for group join to enable AutoCommitTask if broker version < 0.9 * For zookeeper offset storage, set a "coordinator" with least_loaded_node
* enable errors on callbacks in testing. fix broken test.Zack Dever2016-04-251-1/+1
|
* Beginnings of metrics instrumentation in kafka consumer.Zack Dever2016-04-131-6/+13
| | | | | | This adds the parent metrics instance to kafka consumer, which will eventually be used to instrument everything under consumer. To start I ported the java consumer coordinator metrics.
* Consolidate conn fixture definitionsDana Powers2016-04-071-13/+0
|
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-051-34/+33
|
* KAFKA-3318: clean up consumer logging and error messagesDana Powers2016-04-051-3/+3
|
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-3/+2
|
* Test _maybe_auto_commit_offsets_sync when group_id is NoneDana Powers2016-04-031-19/+35
|
* Add test for unknown coordinator heartbeat taskDana Powers2016-03-121-2/+14
|
* Mock client.ready() call to test coordinator offset fetch requestDana Powers2016-02-191-0/+1
|
* break up some circular references and close client wake pipe on __del__aisch2016-02-161-1/+2
|
* Add RangePartitionAssignor (and use as default); add assignor testsrange_assignorDana Powers2016-02-161-7/+11
|
* Add mocking to test_coordinator::test_close to fix random test failure (via ↵Dana Powers2016-01-111-0/+1
| | | | travis logs)
* Add ConsumerCoordinator unit testsDana Powers2016-01-101-0/+568
View Lorry Controller Status