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

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

instrument metrics for fetch requests

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

Update imports from kafka.common -> kafka.errors / kafka.structs

2016-04-05T16:35:45+00:00

Merge pull request #602 from zackdever/KAFKA-2698

2016-03-17T18:22:36+00:00

KAFKA-2698: add paused API

Add default_offset_commit_callback to KafkaConsumer DEFAULT_CONFIGS

2016-03-17T18:21:48+00:00

KAFKA-2698: add paused API

2016-03-17T01:01:17+00:00