delta/python-packages/kafka-python.git/kafka/consumer, branch ssl_set_ciphers

Allow configuration of SSL Ciphers

2019-03-21T15:32:45+00:00

Error if connections_max_idle_ms not larger than request_timeout_ms (#1688)

2019-03-15T00:34:59+00:00

1701 use last offset from fetch v4 if available (#1724)

2019-03-13T13:48:53+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()

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