delta/python-packages/kafka-python.git/kafka/protocol, branch fix-sphinx-docs

KAFKA-3888 Use background thread to process consumer heartbeats (#1266)

2017-12-21T22:46:10+00:00

Minor Exception cleanup

2017-12-12T19:06:44+00:00

Raise better struct pack/unpack errors (#1320)

2017-12-12T17:21:50+00:00

Fix two bugs in printing bytes instance

2017-11-27T20:45:07+00:00

Bug 1:
When `value` is None, trying to call `len(None)` throws an exception.

Bug 2:
When len(`value`) <= 100, the code currently prints b'' rather than
`value`.

Added limit of 100 bytes for Bytes debug prints

2017-10-14T09:59:09+00:00

Added minor fixes for PR review

2017-10-12T08:10:44+00:00

Refactor MessageSet and Message into LegacyRecordBatch to later support v2 message format

2017-10-11T15:09:17+00:00

Add kafka.protocol.parser.KafkaProtocol w/ receive and send (#1230)

2017-10-10T17:15:40+00:00

BrokerConnection receive bytes pipe (#1032)

2017-08-15T20:00:02+00:00

Added basic support for offsets_for_times API. Still needs to group by nodes and send in parallel.

2017-08-07T09:34:08+00:00