delta/python-packages/kafka-python.git/kafka, branch reduce_client_locks

Do not require client lock for read-only operations

2019-03-06T16:00:18+00:00

Remove unused import

2019-01-28T19:01:42+00:00

Improve KafkaConsumer join group / only enable Heartbeat Thread during stable group (#1695)

2019-01-15T16:08:45+00:00

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.

Timeout all unconnected conns (incl SSL) after request_timeout_ms

2019-01-13T16:52:32+00:00

Fix `AttributeError` caused by `getattr()`

2019-01-07T20:57:25+00:00

`getattr(object, 'x', object.y)` will evaluate the default argument
`object.y` regardless of whether `'x'` exists.

For details see: https://stackoverflow.com/q/31443989/770425

Fix SSL connection testing in Python 3.7

2019-01-03T21:54:59+00:00

Fix response error checking in KafkaAdminClient send_to_controller

2019-01-03T21:46:47+00:00

Previously we weren't accounting for when the response tuple also has a
`error_message` value.

Note that in Java, the error fieldname is inconsistent:
 - `CreateTopicsResponse` / `CreatePartitionsResponse` uses `topic_errors`
 - `DeleteTopicsResponse` uses `topic_error_codes`
So this updates the `CreateTopicsResponse` classes to match.

The fix is a little brittle, but should suffice for now.

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

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

Bugfix: Types need identity comparison

2018-12-13T10:35:00+00:00

`isinstance()` won't work here, as the types require identity comparison.