Dana Powers bce0cad5d3 Revisit _wait_on_metadata to address timeout and error handling (Issue 539)

2016-02-15 16:24:02 -08:00

..

__init__.py

Add KafkaProducer to kafka and kafka.producer module imports

2016-01-24 17:33:09 -08:00

base.py

Fixup RequestTimeoutError -> RequestTimedOutError

2016-02-15 11:05:41 -08:00

buffer.py

Add support for LZ4 compressed messages using python-lz4 module

2016-01-25 10:09:15 -08:00

future.py

Add thread-aware futures for use with KafkaProducer

2016-01-24 17:33:08 -08:00

kafka.py

Revisit _wait_on_metadata to address timeout and error handling (Issue 539)

2016-02-15 16:24:02 -08:00

keyed.py

Drop kafka_bytestring

2015-12-10 18:37:03 -08:00

record_accumulator.py

Fix accumulator bug: expired batches should be removed from the internal queue

2016-02-02 07:55:39 -08:00

sender.py

Add more debug/trace statements to sender loop

2016-02-02 07:57:04 -08:00

simple.py

Merge branch '0.9'

2016-01-07 18:51:14 -08:00