summaryrefslogtreecommitdiff
path: root/kafka/consumer/base.py
Commit message (Expand)AuthorAgeFilesLines
* Spelling and grammar changes (#923)melissacrawford3962017-01-111-1/+1
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-6/+4
* Add ignore_leadernotavailable kwarg to SimpleClient.load_metadata_for_topicsDana Powers2016-03-131-1/+1
* Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, ...deprecation_warningsDana Powers2016-01-121-0/+4
* Fix KafkaClient->SimpleClient references0.9Dana Powers2016-01-071-1/+1
* Disable pylint errors for py2/py3 compatibility workaroundsDana Powers2016-01-011-1/+2
* Drop kafka_bytestringDana Powers2015-12-101-3/+3
* Convert OffsetCommit and OffsetFetch protocol encode/decodeDana Powers2015-12-101-3/+3
* Update references to kafka.common Request/Response (now Payload)Dana Powers2015-12-091-2/+2
* 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