summaryrefslogtreecommitdiff
path: root/test
Commit message (Expand)AuthorAgeFilesLines
* Reorganize producer integration tests; protect against non-sorted partition m...Dana Powers2015-02-091-121/+160
* Use a different topic for each producer integration test for isolationDana Powers2015-02-091-1/+0
* Add more comments to test_switch_leader regarding req_acks policyDana Powers2015-02-091-3/+10
* Write a test for issue 313 - keyed producer failoverDana Powers2015-02-091-0/+40
* use setUp / tearDown to rebuild fixtures for each test in test_failover_integ...Dana Powers2015-02-091-12/+12
* Just encode to bytes if it isn't bytes.John Anderson2015-01-241-6/+10
* Alert if the topic is not sent as bytesJohn Anderson2015-01-231-0/+11
* Add 0.8.2.0 to some kafka_version testsDana Powers2015-01-142-3/+3
* Change ZookeeperFixture wait_for regex to support newer zk version used with ...Dana Powers2015-01-141-1/+1
* Fix KafkaFixture child stdout / stderr captureDana Powers2015-01-141-2/+2
* Merge pull request #289 from alexcb/broker-error-class-refactoringDana Powers2015-01-121-3/+2
|\
| * Use reflection to avoid multiple errno definitionsAlex Couture-Beil2015-01-101-3/+2
* | Updated unittests to explicitly set random_start valueAlex Couture-Beil2015-01-091-15/+21
|/
* Make TIMEOUT_MS configurable in test_kafka_consumer__blockingDana Powers2014-12-151-4/+5
* Merge conflict w/ assertEqual (assertEquals deprecated)Dana Powers2014-12-157-50/+52
* 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-152-4/+2
* Add a few basic KafkaConsumer testsDana Powers2014-12-152-13/+83
* fix pending methodNickolai Novik2014-12-151-2/+14
* Fixed TestKafkaProducerIntegrationLou Marvin Caraig2014-11-262-17/+29
* Merge pull request #233 from dpkp/str_join_speedupMark Roberts2014-09-112-18/+20
|\
| * Use b''.join([]) instead of += to speedup codeDana Powers2014-09-102-18/+20
* | Merge pull request #232 from dpkp/directory_layoutDana Powers2014-09-103-3/+3
|\ \ | |/ |/|
| * Separate consumers/producers/partitionersDana Powers2014-09-103-3/+3
* | Fixup test_context.py unittest importDana Powers2014-09-101-2/+2
* | Merge pull request #217 from locationlabs/transactionDana Powers2014-09-101-0/+117
|\ \ | |/ |/|
| * Rename KafkaTransaction to OffsetCommitContext for clarity.Jesse Myers2014-09-031-20/+20
| * Add transaction context manager.Jesse Myers2014-08-301-0/+117
* | Merge pull request #223 from dpkp/metadata_refactorDana Powers2014-09-083-121/+255
|\ \
| * | Add client unit tests for has_metadata_for_topic and ensure_topic_existsDana Powers2014-09-011-1/+63
| * | Add test for sending produce request to unknown topic w/o auto-creationDana Powers2014-09-011-0/+25
| * | Use standard exceptions in client._get_leader_for_partition()Dana Powers2014-09-013-18/+20
| * | load_metadata_for_topics should raise exceptions on explicit topic argsDana Powers2014-09-011-25/+46
| * | Refactor internal metadata dicts in KafkaClientDana Powers2014-09-011-1/+2
| * | No more custom LeaderUnavailableError exception -- raise LeaderNotAvailableErrorDana Powers2014-09-012-4/+3
| * | Improve metadata protocol handlingDana Powers2014-09-012-109/+123
* | | Merge pull request #227 from wizzat-feature/py3Dana Powers2014-09-0716-299/+334
|\ \ \
| * | | Fix the multiprocessing tests for python 3Mark Roberts2014-09-031-1/+1
| * | | Fix test errors related to mocksMark Roberts2014-09-031-3/+6
| * | | Fix more tests, only multiprocessing consumer ones remainingBruno Renié2014-09-036-20/+32
| * | | Bytes in self.msg()Bruno Renié2014-09-031-1/+1
| * | | More bytes topicsBruno Renié2014-09-032-2/+2
| * | | Encode topic directlyBruno Renié2014-09-031-1/+2
| * | | Fix bytes interpolationBruno Renié2014-09-031-1/+1
| * | | Topic in bytesBruno Renié2014-09-031-1/+1
| * | | Fix stderr captureBruno Renié2014-09-031-1/+1
| * | | Fix log capture on py3Bruno Renié2014-09-031-1/+1
| * | | Make all unit tests pass on py3.3/3.4Bruno Renié2014-09-0311-241/+257
| * | | Use base unittest or unittest2 depending on python versionBruno Renié2014-09-0312-29/+37
| |/ /
* | | Cleanup tests: no more import *; remove unusedDana Powers2014-09-049-54/+26