Taras Voinarovskyi c8237fc53b Add note, that max_in_flight_requests_per_connection>1 may change order or messages (#1149)

2017-07-17 16:39:37 -07:00

..

__init__.py

Always absolute_import

2016-08-02 21:36:00 -07:00

base.py

Use logging's built-in string interpolation

2017-07-07 13:40:31 -07:00

buffer.py

Issue 985: Clear memory wait condition before raising Exception (#999)

2017-03-02 11:27:07 -08:00

future.py

KAFKA-3196: Add checksum and size to RecordMetadata and ConsumerRecord (#770 / #594)

2016-07-17 11:44:01 -07:00

kafka.py

Add note, that max_in_flight_requests_per_connection>1 may change order or messages (#1149)

2017-07-17 16:39:37 -07:00

keyed.py

Add ignore_leadernotavailable kwarg to SimpleClient.load_metadata_for_topics

2016-03-13 09:35:49 -07:00

record_accumulator.py

raise KafkaTimeoutException when flush times out

2017-06-16 23:21:11 -07:00

sender.py

Instrument metrics in BrokerConnection

2016-08-04 13:05:36 -07:00

simple.py

Vendor six 1.10.0

2016-08-01 14:47:40 -07:00