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

Fix byte size estimation with kafka producer (#1393)

2018-02-24T16:14:09+00:00

use absolute imports everywhere (#1362)

2018-02-06T20:10:45+00:00

fix reconnect_backoff_max_ms default config bug in KafkaProducer (#1352)

2018-01-23T17:48:58+00:00

Read all available socket bytes (#1332)

2018-01-11T01:25:33+00:00

* Recv all available network bytes before parsing
* Add experimental support for configuring socket chunking parameters

Raise non-API exceptions (#1316)

2017-12-21T22:48:15+00:00

The original intent was to catch API exceptions (errors returned by the
broker when trying to produce a message) and delegate them to the
messages' futures. This is copied from the Java producer.

However, we were accidentally catching all exceptions, thereby hiding
exceptions from users unless they explicitly check the result of the
future. Much better to raise client-side errors directly in the
foreground so the user is immediately aware of them and can decide how
to handle.

Fix #1274

use python standard max value (#1303)

2017-12-07T21:59:58+00:00

Add DefaultRecordBatch implementation aka V2 message format parser/builder. (#1185)

2017-10-24T22:28:35+00:00

Added bytecode optimization for varint and append/read_msg functions. Mostly based on avoiding LOAD_GLOBAL calls.

Fix timestamp not passed to RecordMetadata (#1273)

2017-10-22T07:56:28+00:00

* Fix timestamp not being passed to RecordMetadata properly

* Add more tests for LegacyBatch

* Fix producer test for recordmetadata

Fix overriding sasl_kerberos_service_name in KafkaConsumer / KafkaProducer (#1264)

2017-10-17T23:03:33+00:00

Added minor fixes for PR review

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