| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Fix KafkaClient->SimpleClient references0.9 | Dana Powers | 2016-01-07 | 1 | -1/+1 |
| | | |||||
| * | Disable pylint errors for py2/py3 compatibility workarounds | Dana Powers | 2016-01-01 | 1 | -1/+2 |
| | | |||||
| * | Drop kafka_bytestring | Dana Powers | 2015-12-10 | 1 | -3/+3 |
| | | |||||
| * | Convert OffsetCommit and OffsetFetch protocol encode/decode | Dana Powers | 2015-12-10 | 1 | -3/+3 |
| | | |||||
| * | Update references to kafka.common Request/Response (now Payload) | Dana Powers | 2015-12-09 | 1 | -2/+2 |
| | | |||||
| * | Merge pull request #456 from barricadeio/mp-retry | Dana Powers | 2015-12-02 | 1 | -0/+1 |
| |\ | | | | | Support retry semantics in MultiProcessConsumer | ||||
| | * | Support retry semantics in MultiProcessConsumer | Ross Duggan | 2015-09-14 | 1 | -0/+1 |
| | | | |||||
| * | | allow to retrieve partition info in mp consumer | Martin Olveyra | 2015-06-29 | 1 | -0/+8 |
| |/ | |||||
| * | Lower logging level on replica not available and commit | Enrico Canzonieri | 2015-06-19 | 1 | -1/+1 |
| | | |||||
| * | Change Consumer commit() to return True/False and log error; dont raise ↵ | Dana Powers | 2015-06-10 | 1 | -12/+18 |
| | | | | | client exceptions | ||||
| * | Use separate module loggers instead of a single 'kafka' logger | Dana Powers | 2015-06-06 | 1 | -1/+2 |
| | | |||||
| * | Check vs None directly. | William Ting | 2015-05-17 | 1 | -4/+4 |
| | | |||||
| * | Merge pull request #360 from dpkp/atexit_cleanup | Dana Powers | 2015-04-04 | 1 | -3/+25 |
| |\ | | | | | Register atexit handlers for consumer and producer thread/multiprocess cleanup | ||||
| | * | Register atexit handlers for consumer and producer thread/multiprocess ↵ | Dana Powers | 2015-03-31 | 1 | -3/+25 |
| | | | | | | | | | cleanup (not __del__) | ||||
| * | | Make external API consistently support python3 strings for topic. | Space | 2015-04-03 | 1 | -3/+3 |
| |/ | |||||
| * | Bulk fetch offset partitions in base consumer -- suggested by ecanzonieri | Dana Powers | 2015-03-30 | 1 | -8/+9 |
| | | |||||
| * | Fetch previously committed offsets in base consumer class so long as | Dana Powers | 2015-03-30 | 1 | -12/+25 |
| | | | | | | | | | a group is configured (but document that group must be None for old servers). This fixes multiprocessor consumer issue that prevented access to commit offsets if auto_commit is disabled. Also refactor fetch_last_known_offsets based on KafkaConsumer While still setting unknown offsets to 0 | ||||
| * | Stop consumers on delete | Dana Powers | 2015-03-30 | 1 | -0/+3 |
| | | |||||
| * | Manageable queue.put() operation for MPConsumer processes | Viktor Shlapakov | 2015-03-25 | 1 | -0/+1 |
| | | |||||
| * | Add Sphinx API docs | Will Daly | 2015-01-15 | 1 | -3/+7 |
| | | |||||
| * | fix pending method | Nickolai Novik | 2014-12-15 | 1 | -1/+1 |
| | | |||||
| * | Separate consumers/producers/partitioners | Dana Powers | 2014-09-10 | 1 | -0/+169 |
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |