summaryrefslogtreecommitdiff
path: root/test/test_consumer.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2019-03-14 09:39:28 -0700
committerJeff Widman <jeff@jeffwidman.com>2019-03-14 09:39:28 -0700
commit812de351f75beefe73bd9bef55847ab61ccc951d (patch)
treec0122d099cbe0ff0c2c3a1adf76dc09493ae8bcf /test/test_consumer.py
parent703f06590be2daa7e4592b3d82df6d719a6829bb (diff)
downloadkafka-python-812de351f75beefe73bd9bef55847ab61ccc951d.tar.gz
Retry bootstrapping after backoff when necessary (#1736)
The current client attempts to bootstrap once during initialization, but if it fails there is no second attempt and the client will be inoperable. This can happen, for example, if an entire cluster is down at the time a long-running client starts execution. This commit attempts to fix this by removing the synchronous bootstrapping from `KafkaClient` init, and instead merges bootstrap metadata with the cluster metadata. The Java client uses a similar approach. This allows us to continue falling back to bootstrap data when necessary throughout the life of a long-running consumer or producer. Fix #1670
Diffstat (limited to 'test/test_consumer.py')
0 files changed, 0 insertions, 0 deletions