summaryrefslogtreecommitdiff
path: root/test
Commit message (Collapse)AuthorAgeFilesLines
...
| * Fix test_conn tests wrt _dirty / _sockDana Powers2014-08-191-9/+4
| |
| * Remove unused imports from test/test_conn.pyDana Powers2014-08-191-2/+0
| |
| * Implement last of the skipped test_conn.py testsDana Powers2014-08-191-2/+18
| |
| * Implement a few more skipped tests in test/test_conn.pyDana Powers2014-08-191-4/+19
| |
| * Move common connection testing code to setUp methodDana Powers2014-08-191-98/+45
| |
| * Implementing more skipped connection tests (send and recv)Dana Powers2014-08-191-6/+82
| |
| * Cleanup some connection tests in test/test_conn.pyDana Powers2014-08-191-14/+11
| |
| * Improve KafkaConnection testing: mock socket.create_connection; add tests ↵Dana Powers2014-08-191-8/+95
| | | | | | | | for __init__ and send
* | Merge pull request #204 from mdaniel/better-type-errorsDana Powers2014-08-221-12/+27
|\ \ | | | | | | Better type errors
| * | Failing test for write_int and write_shortMatthew L Daniel2014-08-221-0/+16
| | |
| * | PEP8 fixesMatthew L Daniel2014-08-221-12/+11
| |/
* | Add KafkaTimeoutError (used by client.ensure_topic_exists) and add a testDana Powers2014-08-141-0/+11
|/
* Increase fixture wait timeout to 30s; add wait-time loggingDana Powers2014-08-131-2/+4
|
* Add kafka 0.8.1.1 to integration tests.Dana Powers2014-08-133-17/+2
| | | | | | - 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.
* Use kafka_run_class_env() to set environment vars in test fixturesDana Powers2014-08-122-17/+17
|
* Download official binaries from apache.org for integration testsDana Powers2014-08-121-1/+5
|
* Add Fixtures.download_official_distribution to get binaries from apache.orgDana Powers2014-08-121-0/+39
|
* Fix Py26 test casesMark Roberts2014-05-221-1/+1
|
* Handle New Topic CreationMark Roberts2014-05-222-12/+10
| | | | | Adds ensure_topic_exists to KafkaClient, redirects test case to use that. Fixes #113 and fixes #150.
* Improve error handling and tests w.r.t. codecsPatrick Lucas2014-05-071-6/+58
| | | | | | | | | | Add function kafka.protocol.create_message_set() that takes a list of payloads and a codec and returns a message set with the desired encoding. Introduce kafka.common.UnsupportedCodecError, raised if an unknown codec is specified. Include a test for the new function.
* Merge branch 'teach_producers_about_compression' into producer_compressionMark Roberts2014-05-071-5/+4
|\ | | | | | | | | | | Conflicts: servers/0.8.0/kafka-src test/test_unit.py
| * Add 'codec' parameter to ProducerPatrick Lucas2014-05-031-4/+4
| | | | | | | | | | Adds a codec parameter to Producer.__init__ that lets the user choose a compression codec to use for all messages sent by it.
* | Make test suite more robust against very slow test suitesMark Roberts2014-05-061-2/+2
| |
* | Merge branch 'master' into add_testsMark Roberts2014-05-061-6/+24
|\ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | kafka/client.py contained duplicate copies of same refactor, merged. Move test/test_integration.py changes into test/test_producer_integration. Conflicts: kafka/client.py servers/0.8.0/kafka-src test/test_integration.py
| * \ Merge pull request #139 from alexcb/masterDana Powers2014-05-061-23/+58
| |\ \ | | |/ | |/| SimpleProducer randomization of initial round robin ordering
| | * Modified SimpleProducer-based integration tests to work now thatAlex Couture-Beil2014-03-121-23/+58
| | | | | | | | | | | | the initial round-robin ordering of partitions have been randomized
* | | Attempt to fix travis build. Decrease complexity of service.py in favor of ↵Mark Roberts2014-05-063-58/+26
| | | | | | | | | | | | in memory logging. Address code review concerns
* | | Add missing importMark Roberts2014-04-301-0/+1
| | |
* | | Skip flaky test between osx/linuxMark Roberts2014-04-301-1/+1
| | |
* | | Various fixesMark Roberts2014-04-253-12/+122
| | | | | | | | | | | | | | | | | | | | | | | | Bump version number to 0.9.1 Update readme to show supported Kafka/Python versions Validate arguments in consumer.py, add initial consumer unit test Make service kill() child processes when startup fails Add tests for util.py, fix Python 2.6 specific bug.
* | | Fix last remaining test by making autocommit more intuitiveMark Roberts2014-04-241-2/+2
| | |
* | | Fix Python 2.6 supportMark Roberts2014-04-2311-53/+37
| | |
* | | Update consumer_integration to flip the autocommit switch when testing kafka ↵Mark Roberts2014-04-231-30/+36
| | | | | | | | | | | | 0.8.1
* | | Split out kafka version environments, default tox no longer runs any ↵Mark Roberts2014-04-237-25/+85
| | | | | | | | | | | | 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 Roberts2014-04-237-12/+51
| | | | | | | | | | | | specific test. Add rudimentary (failing) consumer resumption test
* | | Add support for kafka 0.8.1Mark Roberts2014-04-232-4/+9
| | |
* | | Move kafka-src to servers/0.8.0/kafka-src, move test/resources to ↵Mark Roberts2014-04-234-105/+4
| | | | | | | | | | | | servers/0.8.0/resources, update fixtures, add build_integration.sh for getting started with development
* | | Update fixtures to eliminate extraneous logging on non-errors, split out ↵Mark Roberts2014-04-225-221/+240
| | | | | | | | | | | | mostly unrelated service.py, fix test in client_integration to use get_open_port, fix unintended import cascade in test_producer_integration
* | | Fix bug in socket timeout per PR #161 by maciejkula, add testMark Roberts2014-04-191-3/+13
| | |
* | | Finish breaking out integration testsMark Roberts2014-04-175-933/+387
| | |
* | | Split up and speed up producer based integration testsMark Roberts2014-04-172-71/+342
| | |
* | | Split out and speed up producer testsMark Roberts2014-04-171-0/+139
| | |
* | | Refactor away _get_conn_for_broker. Fix bug in _get_connMark Roberts2014-04-091-1/+1
| | |
* | | Add final tests for 100% coverage of protocol.py from test/test_protocol.pyMark Roberts2014-04-091-6/+63
| | |
* | | Add encode_offset_fetch_request testMark Roberts2014-04-091-9/+40
| | |
* | | Add commit offset request testMark Roberts2014-04-091-26/+47
| | |
* | | Add tests for encode_offset_requestMark Roberts2014-04-091-3/+43
| | |
* | | Add python-snappy to tox dependencies. Fix snappy protocol testMark Roberts2014-04-091-27/+36
| | |
* | | Convert test_encode_fetch_request to struct.pack format, improve test ↵Mark Roberts2014-04-091-12/+45
| | | | | | | | | | | | reliability
* | | Update more tests, fix intermittent failureMark Roberts2014-04-091-40/+89
| | |
View Lorry Controller Status