| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| | * | | | | Stopping daemonized threads when references to these threads are lost | Christophe-Marie Duquesne | 2015-03-02 | 2 | -0/+9 | |
| | |/ / / | ||||||
| * | | | | Merge pull request #328 from wkiser/validate_offset | Dana Powers | 2015-03-02 | 2 | -0/+8 | |
| |\ \ \ \ | | | | | | | | | | | 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 | 2 | -0/+8 | |
| | |/ / / | | | | | | | | | | | | | message's offset is greater than or equal to the consumer offset. | |||||
| * | | | | Merge pull request #296 from ecanzonieri/validate_consumer_offset | Dana Powers | 2015-03-02 | 2 | -4/+97 | |
| |\ \ \ \ | |/ / / |/| | | | Validate consumer offset in SimpleConsumer | |||||
| | * | | | Retry failed partitions and add integration tests | Enrico Canzonieri | 2015-01-26 | 2 | -1/+45 | |
| | | | | | ||||||
| | * | | | Merge branch 'master' of github.com:mumrah/kafka-python into ↵ | Enrico Canzonieri | 2015-01-26 | 35 | -596/+1652 | |
| | |\ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | validate_consumer_offset Conflicts: kafka/consumer/simple.py | |||||
| | * | | | | 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 #314 from dpkp/keyed_producer_failover | Dana Powers | 2015-02-19 | 6 | -145/+231 | |
| |\ \ \ \ \ | |_|_|_|/ |/| | | | | Handle keyed producer failover | |||||
| | * | | | | Reorganize producer integration tests; protect against non-sorted partition ↵ | Dana Powers | 2015-02-09 | 1 | -121/+160 | |
| | | | | | | | | | | | | | | | | | | | | | metadata | |||||
| | * | | | | Use a different topic for each producer integration test for isolation | Dana Powers | 2015-02-09 | 1 | -1/+0 | |
| | | | | | | ||||||
| | * | | | | Always use the initial partition list when hashing keys in KeyedProducer | Dana Powers | 2015-02-09 | 1 | -1/+1 | |
| | | | | | | ||||||
| | * | | | | make partitions arg optional in *Partitioner.partition, defaulting to ↵ | Dana Powers | 2015-02-09 | 3 | -7/+8 | |
| | | | | | | | | | | | | | | | | | | | | | self.partitions from init | |||||
| | * | | | | Add more comments to test_switch_leader regarding req_acks policy | Dana Powers | 2015-02-09 | 1 | -3/+10 | |
| | | | | | | ||||||
| | * | | | | Write a test for issue 313 - keyed producer failover | Dana Powers | 2015-02-09 | 1 | -0/+40 | |
| | | | | | | ||||||
| | * | | | | use setUp / tearDown to rebuild fixtures for each test in ↵ | Dana Powers | 2015-02-09 | 1 | -12/+12 | |
| | | | | | | | | | | | | | | | | | | | | | test_failover_integration | |||||
| * | | | | | Merge pull request #317 from sontek/update_consumer_docs | Dana Powers | 2015-02-10 | 2 | -5/+10 | |
| |\ \ \ \ \ | | | | | | | | | | | | | Updated documentation for Consumers to prefer KafkaConsumer instead | |||||
| | * | | | | | Updated documentation for Consumers to prefer KafkaConsumer instead | John Anderson | 2015-02-09 | 2 | -5/+10 | |
| | | | | | | | ||||||
| * | | | | | | Merge pull request #316 from sontek/add_docs_to_tox | Dana Powers | 2015-02-10 | 9 | -70/+230 | |
| |\ \ \ \ \ \ | | | | | | | | | | | | | | | Allow better usage of docs locally. | |||||
| | * | | | | | | Need to commit apidoc for RTD | John Anderson | 2015-02-10 | 6 | -1/+208 | |
| | | | | | | | | ||||||
| | * | | | | | | Use sphinx-apidoc to to generate API docs | John Anderson | 2015-02-10 | 5 | -66/+5 | |
| | | | | | | | | ||||||
| | * | | | | | | Allow better usage of docs locally. | John Anderson | 2015-02-09 | 3 | -4/+18 | |
| | | |/ / / / | |/| | | | | | | | | | | | | | | | | | | | | | | This will default to the rtd theme and introduces tox -e docs for generating docs locally. | |||||
| * | | | | | | Merge pull request #321 from sontek/switch_to_rst | Dana Powers | 2015-02-10 | 3 | -48/+63 | |
| |\ \ \ \ \ \ | | | | | | | | | | | | | | | Switch to rst and use in setup.py | |||||
| | * | | | | | | Added py3 to classifiers | John Anderson | 2015-02-10 | 1 | -0/+3 | |
| | | | | | | | | ||||||
| | * | | | | | | Final formatting | John Anderson | 2015-02-10 | 1 | -2/+4 | |
| | | | | | | | | ||||||
| | * | | | | | | More formatting cleanup | John Anderson | 2015-02-10 | 1 | -2/+2 | |
| | | | | | | | | ||||||
| | * | | | | | | Cleaned up some formatting | John Anderson | 2015-02-10 | 1 | -7/+7 | |
| | | | | | | | | ||||||
| | * | | | | | | Move to .rst and use it in setup.py for long description | John Anderson | 2015-02-10 | 2 | -14/+24 | |
| |/ / / / / / | ||||||
| * | | | | | | Merge pull request #320 from sontek/dont_link_to_mobile | David Arthur | 2015-02-10 | 1 | -1/+1 | |
| |\ \ \ \ \ \ | |/ / / / / |/| | | | | | This links to the main page not the mobile site | |||||
| | * | | | | | This links to the main page not the mobile site | John Anderson | 2015-02-10 | 1 | -1/+1 | |
| |/ / / / / | ||||||
| * | | | | | Merge pull request #315 from dpkp/sorted_partition_ids | Mark Roberts | 2015-02-09 | 1 | -1/+1 | |
| |\ \ \ \ \ | |/ / / / |/| | | | | Always return sorted partition ids in client.get_partition_ids_for_topic() | |||||
| | * | | | | Always return sorted partition ids in KafkaClient.get_partition_ids_for_topic() | Dana Powers | 2015-02-09 | 1 | -1/+1 | |
| |/ / / / | ||||||
| * | | | | Fixup index.rst | Dana Powers | 2015-02-05 | 1 | -0/+1 | |
| | | | | | ||||||
| * | | | | Update docs/index.rst for sphinx/RTD | Dana Powers | 2015-02-05 | 1 | -7/+8 | |
| | | | | | ||||||
| * | | | | 2014 -> 2015 | David Arthur | 2015-02-03 | 3 | -3/+3 | |
| | | | | | ||||||
| * | | | | Adding ReadTheDocs badge | David Arthur | 2015-02-03 | 1 | -1/+2 | |
| | | | | | | | | | | | | | Because you can never have enough badges | |||||
| * | | | | Removing traces of queue.py | David Arthur | 2015-02-03 | 2 | -4/+1 | |
| | | | | | ||||||
| * | | | | Removing queue.py | David Arthur | 2015-02-03 | 1 | -215/+0 | |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | It's just collecting dust and throwing off the coverage report. I pushed a branch queue-fixup in case someone wants to take a stab at refactoring it. | |||||
| * | | | | Trying to get ReadTheDocs workingqueue-fixup | David Arthur | 2015-02-03 | 1 | -1/+1 | |
| | | | | | ||||||
| * | | | | Bump VERSION for development of next release | Dana Powers | 2015-02-03 | 1 | -1/+1 | |
| | | | | | ||||||
| * | | | | Update LICENSEv0.9.3 | David Arthur | 2015-02-03 | 1 | -1/+1 | |
| | | | | | ||||||
| * | | | | Bump VERSION | Dana Powers | 2015-02-03 | 1 | -1/+1 | |
| | | | | | ||||||
| * | | | | Merge pull request #310 from dpkp/kafka_python_0_9_3 | Dana Powers | 2015-02-03 | 4 | -12/+43 | |
| |\ \ \ \ | | | | | | | | | | | kafka-python 0.9.3 | |||||
| | * | | | | Update README and CHANGES for 0.9.3 release | Dana Powers | 2015-02-03 | 2 | -7/+31 | |
| | | | | | | ||||||
| | * | | | | Add 0.8.2.0 to integration tests (and use recommended scala 2.10 by default) | Dana Powers | 2015-02-03 | 2 | -5/+12 | |
| |/ / / / | ||||||
| * | | | | Merge pull request #307 from sontek/enable_coveralls | Dana Powers | 2015-02-03 | 1 | -1/+4 | |
| |\ \ \ \ | | | | | | | | | | | This enables coveralls with travis | |||||
| | * | | | | This enables coveralls with travis | John Anderson | 2015-01-24 | 1 | -1/+4 | |
| | | |/ / | |/| | | ||||||
| * | | | | Merge pull request #312 from dpkp/reentrant_timer_py26 | Dana Powers | 2015-02-03 | 1 | -1/+5 | |
| |\ \ \ \ | | | | | | | | | | | Fix python2.6 threading.Event bug in ReentrantTimer | |||||
| | * | | | | Fix python2.6 threading.Event bug in ReentrantTimer | Dana Powers | 2015-02-03 | 1 | -1/+5 | |
| |/ / / / | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |