diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-06-19 08:26:30 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2016-06-19 08:26:30 -0700 |
| commit | 461ccbd9ecf06722c9ff73f6ed439be4b8391672 (patch) | |
| tree | a4bc99969cce7b0f3b3f18ae85658cff6bc33117 /test/test_client_async.py | |
| parent | 0b5a49e58d16336c1a632a4f5e42bc4fbbb3d118 (diff) | |
| download | kafka-python-461ccbd9ecf06722c9ff73f6ed439be4b8391672.tar.gz | |
check_version should scan nodes until version found or timeout (#731)
* Mute all connection logging during conn.check_version
* Always process pending MetadataRequest in conn.check_version
* KakfaClient.check_version: Scan all brokers until a version is identified or timeout
Diffstat (limited to 'test/test_client_async.py')
0 files changed, 0 insertions, 0 deletions