delta/python-packages/kafka-python.git/test/test_client_async.py, branch benchmark_fixups

Retry bootstrapping after backoff when necessary (#1736)

2019-03-14T16:39:28+00:00

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

Recheck connecting nodes sooner when refreshing metadata (#1737)

2019-03-14T04:38:28+00:00

Do network connections and writes in KafkaClient.poll() (#1729)

2019-03-08T16:01:48+00:00

* Add BrokerConnection.send_pending_requests to support async network sends
* Send network requests during KafkaClient.poll() rather than in KafkaClient.send()
* Dont acquire lock during KafkaClient.send if node is connected / ready
* Move all network connection IO into KafkaClient.poll()

Don't use `kafka.common` internally

2018-06-05T21:32:01+00:00

This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`.

Add BrokerConnection.connect_blocking() (#1411)

2018-03-09T19:54:06+00:00

KAFKA-3888 Use background thread to process consumer heartbeats (#1266)

2017-12-21T22:46:10+00:00

Drop unused sleep kwarg to poll (#1177)

2017-08-15T19:59:35+00:00

Timeout idle connections via connections_max_idle_ms (#1068)

2017-04-10T17:06:46+00:00

Avoid multiple connection attempts when refreshing metadata (#1067)

2017-04-06T06:13:02+00:00

Derive all api classes from Request / Response base classes (#1030)

2017-03-14T20:34:37+00:00