| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | Reduce blocking times in consumer integration tests | Dana Powers | 2015-06-08 | 1 | -14/+14 | |
| | | ||||||
| * | Import style nits in integration tests | Dana Powers | 2015-06-08 | 1 | -2/+6 | |
| | | ||||||
| * | random_string helper should return str not bytes | Dana Powers | 2015-06-06 | 1 | -1/+1 | |
| | | ||||||
| * | 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 | -1/+4 | |
| | | | | | | | | | 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 | |||||
| * | Skip these tests: no OffsetCommitRequest for 0.8.0 | Viktor Shlapakov | 2015-03-30 | 1 | -2/+2 | |
| | | ||||||
| * | Added basic tests for load_initial_offsets option | Viktor Shlapakov | 2015-03-30 | 1 | -0/+35 | |
| | | ||||||
| * | Add test case for MP Consumer auto commit | Ali-Akber Saifee | 2015-03-30 | 1 | -0/+35 | |
| | | | | | Tweak MP Consumer test to use iterator | |||||
| * | Use bootstrap_servers interface in tests | Dana Powers | 2015-03-29 | 1 | -1/+1 | |
| | | ||||||
| * | Moving to **kwargs for MPConsumer options | Viktor Shlapakov | 2015-03-24 | 1 | -5/+3 | |
| | | ||||||
| * | Using iter_timeout=0 for MP inner consumer in tests | Viktor Shlapakov | 2015-03-13 | 1 | -1/+4 | |
| | | ||||||
| * | Retry failed partitions and add integration tests | Enrico Canzonieri | 2015-01-26 | 1 | -1/+43 | |
| | | ||||||
| * | Add 0.8.2.0 to some kafka_version tests | Dana Powers | 2015-01-14 | 1 | -2/+2 | |
| | | ||||||
| * | Make TIMEOUT_MS configurable in test_kafka_consumer__blocking | Dana Powers | 2014-12-15 | 1 | -4/+5 | |
| | | ||||||
| * | Merge conflict w/ assertEqual (assertEquals deprecated) | Dana Powers | 2014-12-15 | 1 | -13/+15 | |
| | | ||||||
| * | Fix task_done checks when no previous commit exists; add test | Dana Powers | 2014-12-15 | 1 | -0/+43 | |
| | | ||||||
| * | Move KafkaConsumer to kafka.consumer.kafka module; make available for import ↵ | Dana Powers | 2014-12-15 | 1 | -2/+1 | |
| | | | | | from kafka at top-level | |||||
| * | Add a few basic KafkaConsumer tests | Dana Powers | 2014-12-15 | 1 | -13/+77 | |
| | | ||||||
| * | fix pending method | Nickolai Novik | 2014-12-15 | 1 | -2/+14 | |
| | | ||||||
| * | Separate consumers/producers/partitioners | Dana Powers | 2014-09-10 | 1 | -1/+1 | |
| | | ||||||
| * | Merge pull request #227 from wizzat-feature/py3 | Dana Powers | 2014-09-07 | 1 | -2/+4 | |
| |\ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Python 3 Support Conflicts: kafka/producer.py test/test_client.py test/test_client_integration.py test/test_codec.py test/test_consumer.py test/test_consumer_integration.py test/test_failover_integration.py test/test_producer.py test/test_producer_integration.py test/test_protocol.py test/test_util.py | |||||
| | * | Fix the multiprocessing tests for python 3 | Mark Roberts | 2014-09-03 | 1 | -1/+1 | |
| | | | ||||||
| | * | Fix more tests, only multiprocessing consumer ones remaining | Bruno Renié | 2014-09-03 | 1 | -1/+4 | |
| | | | ||||||
| | * | Make all unit tests pass on py3.3/3.4 | Bruno Renié | 2014-09-03 | 1 | -2/+2 | |
| | | | ||||||
| * | | Cleanup tests: no more import *; remove unused | Dana Powers | 2014-09-04 | 1 | -3/+2 | |
| | | | ||||||
| * | | Import cleanups in tests | Dana Powers | 2014-09-04 | 1 | -5/+8 | |
| |/ | ||||||
| * | Add a test for Issue #135 (Spurious ConsumerFetchSizeTooSmall error) | Dana Powers | 2014-08-26 | 1 | -0/+19 | |
| | | ||||||
| * | Add kafka 0.8.1.1 to integration tests. | Dana Powers | 2014-08-13 | 1 | -1/+1 | |
| | | | | | | | - previous 0.8.1 src appears to have actually been 0.8.1.1 based on git submodule commit. So technically this adds back 0.8.1 to the test suite. | |||||
| * | Make test suite more robust against very slow test suites | Mark Roberts | 2014-05-06 | 1 | -2/+2 | |
| | | ||||||
| * | Attempt to fix travis build. Decrease complexity of service.py in favor of ↵ | Mark Roberts | 2014-05-06 | 1 | -1/+1 | |
| | | | | | in memory logging. Address code review concerns | |||||
| * | Fix last remaining test by making autocommit more intuitive | Mark Roberts | 2014-04-24 | 1 | -2/+2 | |
| | | ||||||
| * | Fix Python 2.6 support | Mark Roberts | 2014-04-23 | 1 | -1/+0 | |
| | | ||||||
| * | Update consumer_integration to flip the autocommit switch when testing kafka ↵ | Mark Roberts | 2014-04-23 | 1 | -30/+36 | |
| | | | | | 0.8.1 | |||||
| * | Split out kafka version environments, default tox no longer runs any ↵ | Mark Roberts | 2014-04-23 | 1 | -7/+24 | |
| | | | | | integration tests, make skipped integration also skip setupClass, implement rudimentary offset support in consumer.py | |||||
| * | Add test support for multiple versions of kafka. Uncomment first 0.8.1 ↵ | Mark Roberts | 2014-04-23 | 1 | -2/+29 | |
| | | | | | specific test. Add rudimentary (failing) consumer resumption test | |||||
| * | Finish breaking out integration tests | Mark Roberts | 2014-04-17 | 1 | -0/+208 | |
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |