summaryrefslogtreecommitdiff
path: root/test/test_consumer_integration.py
Commit message (Expand)AuthorAgeFilesLines
* Support setting kafka instance port explicitly in fixtureDana Powers2016-02-151-2/+4
* Fix missing importDana Powers2016-01-301-0/+1
* Skip MultiProcessConsumer integration testsDana Powers2016-01-301-0/+5
* Merge branch '0.9'Dana Powers2016-01-071-45/+57
|\
| * Dont use consumer_timeout_ms in simple kafka_consumer testDana Powers2016-01-041-2/+1
| * Dont use consumer_timeout_ms in kafka blocking testDana Powers2016-01-031-7/+4
| * Update consumer integration tests to use new (group) KafkaConsumerDana Powers2016-01-031-29/+31
| * Drop bytes encoding of consumer group in consumer integration testDana Powers2015-12-101-1/+1
| * Fix consumer integration test that assumed a single brokerDana Powers2015-12-101-4/+6
| * Fix zk_chroot in consumer integration kafka fixturesDana Powers2015-12-101-2/+3
| * Drop kafka_bytestringDana Powers2015-12-101-1/+1
| * Configure consumer group in consumer_integration testsDana Powers2015-12-101-3/+13
| * Default consumer integration tests should not use offset commitsDana Powers2015-12-091-2/+3
| * Update references to kafka.common Request/Response (now Payload)Dana Powers2015-12-091-2/+2
* | Refactor kafka_versions to support arbitrary operators (> >= < <= ! =)kafka_version_testsDana Powers2015-12-101-20/+5
|/
* Consumers get_messages: allow blocking until some messages are receivedOskari Saarenmaa2015-09-181-0/+18
* fix #410 SimpleConsumer cannot seek to an absolute offset.haosdent2015-06-201-0/+14
* Add kafka 0.8.2.1 to integration tests, remove 0.8.2.0Dana Powers2015-06-101-5/+5
* Reduce blocking times in consumer integration testsDana Powers2015-06-081-14/+14
* Import style nits in integration testsDana Powers2015-06-081-2/+6
* random_string helper should return str not bytesDana Powers2015-06-061-1/+1
* Make external API consistently support python3 strings for topic.Space2015-04-031-1/+1
* Fetch previously committed offsets in base consumer class so long asDana Powers2015-03-301-1/+4
* Skip these tests: no OffsetCommitRequest for 0.8.0Viktor Shlapakov2015-03-301-2/+2
* Added basic tests for load_initial_offsets optionViktor Shlapakov2015-03-301-0/+35
* Add test case for MP Consumer auto commitAli-Akber Saifee2015-03-301-0/+35
* Use bootstrap_servers interface in testsDana Powers2015-03-291-1/+1
* Moving to **kwargs for MPConsumer optionsViktor Shlapakov2015-03-241-5/+3
* Using iter_timeout=0 for MP inner consumer in testsViktor Shlapakov2015-03-131-1/+4
* Retry failed partitions and add integration testsEnrico Canzonieri2015-01-261-1/+43
* Add 0.8.2.0 to some kafka_version testsDana Powers2015-01-141-2/+2
* Make TIMEOUT_MS configurable in test_kafka_consumer__blockingDana Powers2014-12-151-4/+5
* Merge conflict w/ assertEqual (assertEquals deprecated)Dana Powers2014-12-151-13/+15
* Fix task_done checks when no previous commit exists; add testDana Powers2014-12-151-0/+43
* Move KafkaConsumer to kafka.consumer.kafka module; make available for import ...Dana Powers2014-12-151-2/+1
* Add a few basic KafkaConsumer testsDana Powers2014-12-151-13/+77
* fix pending methodNickolai Novik2014-12-151-2/+14
* Separate consumers/producers/partitionersDana Powers2014-09-101-1/+1
* Merge pull request #227 from wizzat-feature/py3Dana Powers2014-09-071-2/+4
|\
| * Fix the multiprocessing tests for python 3Mark Roberts2014-09-031-1/+1
| * Fix more tests, only multiprocessing consumer ones remainingBruno ReniƩ2014-09-031-1/+4
| * Make all unit tests pass on py3.3/3.4Bruno ReniƩ2014-09-031-2/+2
* | Cleanup tests: no more import *; remove unusedDana Powers2014-09-041-3/+2
* | Import cleanups in testsDana Powers2014-09-041-5/+8
|/
* Add a test for Issue #135 (Spurious ConsumerFetchSizeTooSmall error)Dana Powers2014-08-261-0/+19
* Add kafka 0.8.1.1 to integration tests.Dana Powers2014-08-131-1/+1
* Make test suite more robust against very slow test suitesMark Roberts2014-05-061-2/+2
* Attempt to fix travis build. Decrease complexity of service.py in favor of in...Mark Roberts2014-05-061-1/+1
* Fix last remaining test by making autocommit more intuitiveMark Roberts2014-04-241-2/+2
* Fix Python 2.6 supportMark Roberts2014-04-231-1/+0