summaryrefslogtreecommitdiff
path: root/kafka/producer/sender.py
Commit message (Collapse)AuthorAgeFilesLines
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-051-3/+1
|
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-2/+2
|
* remove unused import. needed a change to kick travis.Zack Dever2016-03-141-1/+0
|
* make Sender._topics_to_add a set instead of a listZack Dever2016-03-141-3/+4
|
* Remove unused internal sender lockDana Powers2016-02-151-21/+18
|
* Add more debug/trace statements to sender loopDana Powers2016-02-021-0/+2
|
* Sender class to manage background IO for KafkaProducerDana Powers2016-01-241-0/+272