delta/python-packages/kafka-python.git/kafka/protocol.py, branch simple

Merge pull request #420 from toddpalino/master

2015-12-02T23:50:05+00:00

Initial support for consumer coordinator

allow to specify compression level for codecs which support this

2015-09-12T16:22:50+00:00

Support consumer metadata requests

2015-07-02T05:29:56+00:00

Support added for ConsumerMetadataRequest and ConsumerMetadataResponse
Added consumer-aware request routine for supporting the consumer coordinator
Added separate client method for fetching Kafka-committed offsets from the coordinator

Fixup for loop vars in kafka/protocol.py

2015-06-09T01:59:24+00:00

Use separate module loggers instead of a single 'kafka' logger

2015-06-06T23:11:20+00:00

Correct message keys for async batching mode

2015-02-25T07:01:25+00:00

Add Sphinx API docs

2015-01-15T23:01:40+00:00

Added keys to compressed messages (both gzip and snappy).

2015-01-02T16:34:38+00:00

Added optional argument key to create_message_set function

2014-11-26T10:48:06+00:00

Use b''.join([]) instead of += to speedup code

2014-09-11T06:39:13+00:00