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

KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed messagesets

2016-05-22T16:51:37+00:00

Add CRL support to SSL support (#683)

2016-05-19T14:19:34+00:00

A user can provide a CRL whose peer certificate will be checked
against. This only works with Python 3.4+ and Python 2.7.9+.

Add protocol support for ApiVersionRequest; identify 0.10 brokers in check_version

2016-05-03T03:59:05+00:00

Fix throttle_time_ms sensor

2016-04-25T20:39:42+00:00

Fixes #665

instrument metrics for fetch requests

2016-04-14T00:26:39+00:00

Changing some commented out metrics to avoid future gotchas.

2016-04-14T00:26:39+00:00

Beginnings of metrics instrumentation in kafka consumer.

2016-04-14T00:26:39+00:00

This adds the parent metrics instance to kafka consumer, which will
eventually be used to instrument everything under consumer. To start
I ported the java consumer coordinator metrics.

Add SSL configuration kwargs to KafkaClient, KafkaConsumer, KafkaProducer

2016-04-09T16:24:39+00:00

Default sleep=True in client.poll

2016-04-08T16:23:57+00:00

KAFKA-2136: support Fetch and Produce v1 (throttle_time_ms)

2016-04-06T21:48:13+00:00