Alexey Pervushin 165b897139 Use for join-time-max and sync-time-max metrics Max() measure function (#1146)

2017-07-20 22:07:50 -07:00

..

consumer

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

2017-06-19 10:16:02 -07:00

coordinator

Use for join-time-max and sync-time-max metrics Max() measure function (#1146)

2017-07-20 22:07:50 -07:00

metrics

Fix quota violation exception message (#809)

2016-08-20 17:39:26 -07:00

partitioner

Sort partitions before calling partitioner (#905)

2016-12-19 11:26:03 -08:00

producer

Add note, that max_in_flight_requests_per_connection>1 may change order or messages (#1149)

2017-07-17 16:39:37 -07:00

protocol

Protocol updates for 0.11.0.0 (#1127)

2017-07-09 08:04:39 -07:00

serializer

Add kafka.serializer interfaces (#912)

2016-12-19 11:27:23 -08:00

vendor

Fixed couple of "leaks" when gc is disabled (#979)

2017-03-07 13:31:46 -08:00

__init__.py

Add kafka.serializer interfaces (#912)

2016-12-19 11:27:23 -08:00

client_async.py

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

2017-06-19 10:16:02 -07:00

client.py

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

2017-03-14 13:34:37 -07:00

cluster.py

Add ClusterMetadata documentation

2017-03-07 12:24:55 -08:00

codec.py

LZ4 support in kafka 0.8/0.9 does not accept a ContentSize header

2017-03-14 13:30:35 -07:00

common.py

Always absolute_import

2016-08-02 21:36:00 -07:00

conn.py

added gssapi support (Kerberos) for SASL (#1152)

2017-07-20 10:09:26 -07:00

context.py

Always absolute_import

2016-08-02 21:36:00 -07:00

errors.py

Add new broker response errors

2017-03-04 10:52:44 -08:00

future.py

Always absolute_import

2016-08-02 21:36:00 -07:00

structs.py

Add send_list_offset_request for searching offset by timestamp (#1001)

2017-03-02 14:15:01 -08:00

util.py

Remove dead code (#967)

2017-02-28 10:18:02 -08:00

version.py

Bump version for development

2017-03-14 15:43:16 -07:00