| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Vendor six 1.10.0six | Dana Powers | 2016-08-01 | 1 | -2/+2 |
| | | |||||
| * | Remove unused importskafka-3318 | Dana Powers | 2016-04-05 | 1 | -1/+1 |
| | | |||||
| * | Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, ↵deprecation_warnings | Dana Powers | 2016-01-12 | 1 | -0/+6 |
| | | | | | 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/+1 |
| | | |||||
| * | Disable pylint errors for py2/py3 compatibility workarounds | Dana Powers | 2016-01-01 | 1 | -1/+1 |
| | | |||||
| * | pylint fixes | Dana Powers | 2015-12-10 | 1 | -2/+2 |
| | | | | | | | - temporarily ignore kafka/consumer/group.py - temporarily ignore test/test_protocol.py - disable-msg deprecated; use disable= instead | ||||
| * | Handle PartialMessage / ConsumerFetchSizeTooSmall in SimpleConsumer | Dana Powers | 2015-12-09 | 1 | -21/+24 |
| | | |||||
| * | Update references to kafka.common Request/Response (now Payload) | Dana Powers | 2015-12-09 | 1 | -16/+10 |
| | | |||||
| * | new pylint disables for pylint 1.5.1 | Zack Dever | 2015-12-02 | 1 | -1/+1 |
| | | | | | | tested locally with `pylint --rcfile=pylint.rc -E kafka test`. should pass travis builds. | ||||
| * | 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 | -6/+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 | -6/+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. | ||||
| * | | allow to retrieve partition info in mp consumer | Martin Olveyra | 2015-06-29 | 1 | -7/+0 |
| |/ | |||||
| * | fix #410 SimpleConsumer cannot seek to an absolute offset. | haosdent | 2015-06-20 | 1 | -17/+46 |
| | | |||||
| * | Refactor SimpleConsumer get_messages and _fetch | Dana Powers | 2015-06-10 | 1 | -29/+33 |
| | | | | | | - attempt to make these easier to read - add marginal retry logic to internal _fetch loop | ||||
| * | Merge pull request #405 from dpkp/log_error_type | Dana Powers | 2015-06-10 | 1 | -5/+8 |
| |\ | | | | | Log response error types in consumer and producer logs | ||||
| | * | Add error type to SimpleConsumer error logging | Dana Powers | 2015-06-10 | 1 | -5/+8 |
| | | | |||||
| * | | Change SimpleConsumer.reset_partition_offset to return offset / None on ↵ | Dana Powers | 2015-06-10 | 1 | -5/+19 |
| |/ | | | | failure (dont raise exception) | ||||
| * | Cleanup imports in kafka/client and kafka/consumer | Dana Powers | 2015-06-08 | 1 | -14/+13 |
| | | |||||
| * | SimpleConsumer should refresh metadata and retry on leadership changes; only ↵ | Dana Powers | 2015-06-08 | 1 | -1/+4 |
| | | | | | raise on UnknownTopicOrPartition | ||||
| * | try to fix uncaught FailedPayloadsError | reAsOn2010 | 2015-06-09 | 1 | -1/+8 |
| | | |||||
| * | Use separate module loggers instead of a single 'kafka' logger | Dana Powers | 2015-06-06 | 1 | -1/+3 |
| | | |||||
| * | 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 | ||||
| * | Increase count_since_commit on seek | Enrico Canzonieri | 2015-03-20 | 1 | -1/+1 |
| | | | | | | | When auto_commit is False this change enables an explicit call to commit() to actually commit the offsets. Otherwise a consumer won't be able to commit until at least one message is read. | ||||
| * | Merge pull request #328 from wkiser/validate_offset | Dana Powers | 2015-03-02 | 1 | -0/+4 |
| |\ | | | | | Fixes consumer/kafka and consumer/simple to only yield messages if the m... | ||||
| | * | Fixes consumer/kafka and consumer/simple to only yield messages if the ↵ | wkiser | 2015-03-02 | 1 | -0/+4 |
| | | | | | | | | | message's offset is greater than or equal to the consumer offset. | ||||
| * | | Retry failed partitions and add integration tests | Enrico Canzonieri | 2015-01-26 | 1 | -0/+2 |
| | | | |||||
| * | | Merge branch 'master' of github.com:mumrah/kafka-python into ↵ | Enrico Canzonieri | 2015-01-26 | 1 | -31/+43 |
| |\ \ | |/ | | | | | | | | | | | validate_consumer_offset Conflicts: kafka/consumer/simple.py | ||||
| | * | Add Sphinx API docs | Will Daly | 2015-01-15 | 1 | -28/+39 |
| | | | |||||
| * | | Make SimpleConsumer auto_offset_reset more like KafkaConsumer | Enrico Canzonieri | 2015-01-26 | 1 | -4/+19 |
| | | | |||||
| * | | use a list in send_offset_request | Enrico Canzonieri | 2015-01-14 | 1 | -3/+4 |
| | | | |||||
| * | | Implement offsets reset when OffsetOutOfRangeError | Enrico Canzonieri | 2015-01-14 | 1 | -3/+35 |
| |/ | | | | | | | | This slightly changes the SimpleConsumer interface adding the default option use_latest_offsets. The fetch behaviour is also changed since it does not raise OffsetOutOfRangeError anymore. Resetting the offsets automatically is especially useful in MultiprocessConsumer, where an explicit seek call is not possible. | ||||
| * | Merge pull request #242 from wizzat/pr_225 | Mark Roberts | 2014-09-23 | 1 | -1/+1 |
| |\ | | | | | Resolve merge conflict in PR #225 | ||||
| | * | Resolve merge conflict in PR #225 | Mark Roberts | 2014-09-23 | 1 | -1/+1 |
| | | | |||||
| * | | Fix SimpleConsumer timeout behavior in get_messages (Issue 237) | Dana Powers | 2014-09-21 | 1 | -4/+5 |
| |/ | |||||
| * | Separate consumers/producers/partitioners | Dana Powers | 2014-09-10 | 1 | -0/+318 |
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |