summaryrefslogtreecommitdiff
path: root/kafka/common.py
Commit message (Collapse)AuthorAgeFilesLines
* make changes to be more fault tolerant: clean up connections, brokers, ↵Jim Lim2013-10-041-0/+5
| | | | | | | | failed_messages - add integration tests for sync producer - add integration tests for async producer w. leadership election - use log.exception
* style: fix whitespacesVetoshkin Nikita2013-10-031-0/+4
|
* Fix #44 Add missing exception classv0.8.0David Arthur2013-09-241-0/+16
| | | | Also move the exceptions to common instead of util
* PEP8-ify most of the filesMahendra M2013-05-291-11/+34
| | | | consumer.py and conn.py will be done later after pending merges
* Big code re-orgDavid Arthur2013-04-021-0/+43