delta/python-packages/kafka-python.git/kafka/client_async.py, branch initial_metadata_snapshot

KIP-144: Exponential backoff for broker reconnections (#1124)

2017-06-19T17:16:02+00:00

Fixup for #1085 -- only check for changed metadata on disconnected nodes

2017-06-19T06:18:41+00:00

Deal with brokers that disappear, reappear with different IP address (#1085)

2017-06-19T06:17:31+00:00

When KafkaClient connects to a broker in _maybe_connect,
it inserts into self._conns a BrokerConnection configured
with the current host/port for that node.  The BrokerConnection
remains there forever, though, so if the broker's IP or host
ever changes, KafkaClient has no way to deal with this.

The fix is to compare the latest metadata with the current
node's connection, and if the host/IP has changed, decommission
the old connection and allow a new one to be created.

There's also a common race condition on broker startup where
the initial metadata request sometimes returns an empty list
of brokers, but subsequent requests behave normally.  So, we
must deal with broker being None here.  This change is conservative
in that it doesn't remove the connection from self._conns unless
the new broker metadata contains an entry for that same node
with a new IP/port.

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

Catch socket.errors when sending / recving bytes on wake socketpair (#1069)

2017-04-05T17:11:21+00:00

Fix poll() hyperlink in KafkaClient

2017-03-30T00:35:09+00:00

Previously Sphinx was auto-linking to `poll()` in `KafkaConsumer`, so made the link explicit.

Fix typo (#1054)

2017-03-27T19:40:30+00:00

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

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

Add optional kwarg to ready and is_ready to disable metadata-priority logic (#1017)

2017-03-09T06:53:31+00:00