Dana Powers 12d740ed0d Update KafkaConsumer / KafkaProducer docstrings and defaults

2017-06-18 23:49:50 -07:00

..

__init__.py

Always absolute_import

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

base.py

Add sphinx formatting to hyperlink methods (#898)

2017-03-03 10:14:54 -08: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

Update KafkaConsumer / KafkaProducer docstrings and defaults

2017-06-18 23:49:50 -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