delta/python-packages/kafka-python.git/kafka/producer, branch decode_errors

KAFKA-3388: Fix expiration of batches sitting in the accumulator (#699)

2016-05-23T05:07:33+00:00

KAFKA-3197: when max.in.flight.request.per.connection = 1, attempt to guarantee ordering (#698)

2016-05-23T02:21:35+00:00

Dont use soon-to-be-reserved keyword await as function name (FutureProduceResult) (#697)

2016-05-23T00:16:20+00:00

Use standard LZ4 framing for v1 messages / kafka 0.10 (#695)

2016-05-23T00:14:03+00:00

* LZ4 framing fixed in 0.10 / message v1 -- retain broken lz4 code for compatibility
* lz4f does not support easy incremental decompression - raise RuntimeError
* Update lz4 codec tests

Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694)

2016-05-22T19:41:17+00:00

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

Add SSL configuration kwargs to KafkaClient, KafkaConsumer, KafkaProducer

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

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

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