summaryrefslogtreecommitdiff
path: root/kafka/consumer/base.py
Commit message (Expand)AuthorAgeFilesLines
* Merge pull request #456 from barricadeio/mp-retryDana Powers2015-12-021-0/+1
|\
| * Support retry semantics in MultiProcessConsumerRoss Duggan2015-09-141-0/+1
* | allow to retrieve partition info in mp consumerMartin Olveyra2015-06-291-0/+8
|/
* Lower logging level on replica not available and commitEnrico Canzonieri2015-06-191-1/+1
* Change Consumer commit() to return True/False and log error; dont raise clien...Dana Powers2015-06-101-12/+18
* Use separate module loggers instead of a single 'kafka' loggerDana Powers2015-06-061-1/+2
* Check vs None directly.William Ting2015-05-171-4/+4
* Merge pull request #360 from dpkp/atexit_cleanupDana Powers2015-04-041-3/+25
|\
| * Register atexit handlers for consumer and producer thread/multiprocess cleanu...Dana Powers2015-03-311-3/+25
* | Make external API consistently support python3 strings for topic.Space2015-04-031-3/+3
|/
* Bulk fetch offset partitions in base consumer -- suggested by ecanzonieriDana Powers2015-03-301-8/+9
* Fetch previously committed offsets in base consumer class so long asDana Powers2015-03-301-12/+25
* Stop consumers on deleteDana Powers2015-03-301-0/+3
* Manageable queue.put() operation for MPConsumer processesViktor Shlapakov2015-03-251-0/+1
* Add Sphinx API docsWill Daly2015-01-151-3/+7
* fix pending methodNickolai Novik2014-12-151-1/+1
* Separate consumers/producers/partitionersDana Powers2014-09-101-0/+169