| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Vendor six 1.10.0six | Dana Powers | 2016-08-01 | 1 | -1/+1 |
| | | |||||
| * | Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, ↵deprecation_warnings | Dana Powers | 2016-01-12 | 1 | -0/+5 |
| | | | | | and KafkaConnection | ||||
| * | Fix KafkaClient->SimpleClient references0.9 | Dana Powers | 2016-01-07 | 1 | -1/+1 |
| | | |||||
| * | Import queue from six.moves | Dana Powers | 2016-01-03 | 1 | -4/+2 |
| | | |||||
| * | Fix _mp_consume queue variable name conflict | Dana Powers | 2015-12-09 | 1 | -2/+2 |
| | | |||||
| * | Fix python3 / python2 comments re queue/Queue | Dana Powers | 2015-12-02 | 1 | -5/+5 |
| | | |||||
| * | Merge pull request #457 from saaros/block-for-number-of-messages | Dana Powers | 2015-12-02 | 1 | -5/+9 |
| |\ | | | | | Consumers get_messages: allow blocking until some messages are received | ||||
| | * | Consumers get_messages: allow blocking until some messages are received | Oskari Saarenmaa | 2015-09-18 | 1 | -5/+9 |
| | | | | | | | | | | | | | | | | | | | Modified MultiProcessConsumer's and SimpleConsumer's `block` argument to allow integer value which defines the number of messages to block for. This allows callers to ask for a high number of messages and block only until some of them are received. Otherwise callers would have to request messages one by one or block for some time. | ||||
| * | | Merge pull request #456 from barricadeio/mp-retry | Dana Powers | 2015-12-02 | 1 | -46/+58 |
| |\ \ | | | | | | | Support retry semantics in MultiProcessConsumer | ||||
| | * | | Support retry semantics in MultiProcessConsumer | Ross Duggan | 2015-09-14 | 1 | -46/+58 |
| | |/ | |||||
| * | | allow to retrieve partition info in mp consumer | Martin Olveyra | 2015-06-29 | 1 | -1/+2 |
| |/ | |||||
| * | Cleanup imports in kafka/client and kafka/consumer | Dana Powers | 2015-06-08 | 1 | -8/+7 |
| | | |||||
| * | Merge pull request #380 from dpkp/multiprocess_consumer_partitions | Dana Powers | 2015-06-08 | 1 | -3/+7 |
| |\ | | | | | Support optional partitions kwarg in MultiProcessConsumer | ||||
| | * | Support optional partitions kwarg in MultiProcessConsumer | Dana Powers | 2015-05-17 | 1 | -3/+7 |
| | | | |||||
| * | | Use separate module loggers instead of a single 'kafka' logger | Dana Powers | 2015-06-06 | 1 | -1/+3 |
| |/ | |||||
| * | Make external API consistently support python3 strings for topic. | Space | 2015-04-03 | 1 | -1/+1 |
| | | |||||
| * | Fetch previously committed offsets in base consumer class so long as | Dana Powers | 2015-03-30 | 1 | -0/+2 |
| | | | | | | | | | 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 | ||||
| * | Manageable queue.put() operation for MPConsumer processes | Viktor Shlapakov | 2015-03-25 | 1 | -4/+11 |
| | | |||||
| * | Using mp.manager to solve the issue with join for MPConsumer | Viktor Shlapakov | 2015-03-24 | 1 | -6/+7 |
| | | |||||
| * | Moving to **kwargs for MPConsumer options | Viktor Shlapakov | 2015-03-24 | 1 | -1/+2 |
| | | |||||
| * | Moved additional MP consumer options to **kwargs | Viktor Shlapakov | 2015-03-13 | 1 | -3/+3 |
| | | |||||
| * | Using additional params for MP consumer child process | Viktor Shlapakov | 2015-03-13 | 1 | -26/+32 |
| | | | | | | | | - Moved the events params to a separate param for consistency - Passing additional params to internal SimpleConsumer worker for multiprocessing high-level consumer. It allows to use non-default consumer settings (fetch_size_bytes, buffer_size, max_buffer_size). | ||||
| * | Used thread-safe dict.copy().keys() for MP consumer partitions | Viktor Shlapakov | 2015-03-12 | 1 | -1/+4 |
| | | |||||
| * | Cleaned code for MP consumer chunking | Viktor Shlapakov | 2015-03-11 | 1 | -10/+9 |
| | | |||||
| * | Fixing distribution for MP Consumer | Viktor Shlapakov | 2015-03-03 | 1 | -1/+1 |
| | | |||||
| * | Add Sphinx API docs | Will Daly | 2015-01-15 | 1 | -18/+21 |
| | | |||||
| * | Separate consumers/producers/partitioners | Dana Powers | 2014-09-10 | 1 | -0/+248 |
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |