delta/python-packages/kafka-python.git/kafka/consumer, branch add-python-37-support

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()

Remove unused `skip_double_compressed_messages`

2019-01-13T21:53:18+00:00

This `skip_double_compressed_messages` flag was added in https://github.com/dpkp/kafka-python/pull/755 in
order to fix https://github.com/dpkp/kafka-python/issues/718.

However, grep'ing through the code, it looks like it this is no longer
used anywhere and doesn't do anything.

So removing it.

#1681 add copy() in metrics() to avoid thread safety issues (#1682)

2018-12-27T00:40:30+00:00

Be explicit with tuples for %s formatting

2018-11-18T08:21:18+00:00

Fix #1633

Expose record headers in ConsumerRecords

2018-09-27T22:22:03+00:00

add kerberos domain name config for gssapi sasl mechanism handshake (#1542)

2018-08-31T13:03:26+00:00

Document connections_max_idle_ms

2018-06-26T19:48:41+00:00

This was added in #1068 but never documented.
Fix #1497

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`.

Stop using deprecated log.warn()

2018-05-10T23:33:37+00:00

Fix KafkaConsumer docstring for request_timeout_ms default (#1459)

2018-03-23T15:21:44+00:00