summaryrefslogtreecommitdiff
path: root/test
Commit message (Expand)AuthorAgeFilesLines
...
* | FailedPayloadsError now only has a single payload; use .payload attributeDana Powers2015-06-061-2/+2
* | random_string helper should return str not bytesDana Powers2015-06-064-17/+16
* | Raise an error if we attempt to group duplicate topic-partition payloadsDana Powers2015-06-061-1/+5
* | Module loggers in test/fixtures and test/serviceDana Powers2015-06-062-27/+35
* | Check response.error for async producerViktor Shlapakov2015-06-031-2/+2
* | Improve async producer code: logic and style fixesViktor Shlapakov2015-06-031-33/+20
* | Increase producer test timeoutViktor Shlapakov2015-06-031-1/+1
* | Fix small issues with names/testsViktor Shlapakov2015-06-031-7/+5
* | async queue: refactored code; add one more testEduard Iskandarov2015-06-031-2/+16
* | add producer send batch queue overfilled testИскандаров Эдуард2015-06-031-1/+17
* | Clean and simplify retry logicViktor Shlapakov2015-06-031-3/+5
* | Improved retry logicViktor Shlapakov2015-06-031-3/+3
* | Fixed tests and other issues after rebaseViktor Shlapakov2015-06-031-30/+19
* | Fixed compatible issues with testsViktor Shlapakov2015-06-031-12/+11
* | Producer _send_upstream fixes, added tests for retriesViktor Shlapakov2015-06-031-0/+137
|/
* Make external API consistently support python3 strings for topic.Space2015-04-036-45/+52
* Merge pull request #356 from dpkp/always_fetch_offsetsDana Powers2015-03-302-2/+75
|\
| * Fetch previously committed offsets in base consumer class so long asDana Powers2015-03-302-2/+5
| * 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
* | Merge pull request #355 from dpkp/correlation_id_moduloDana Powers2015-03-301-0/+8
|\ \ | |/ |/|
| * Add test for correlation_id rolloverDana Powers2015-03-291-0/+8
* | Use bootstrap_servers interface in testsDana Powers2015-03-291-1/+1
|/
* Merge pull request #336 from scrapinghub/feature-mp-consumer-paramsDana Powers2015-03-291-2/+3
|\
| * 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
* | Merge pull request #329 from vshlapakov/feature-batch-msg-keysDana Powers2015-03-292-11/+71
|\ \ | |/ |/|
| * Correct message keys for async batching modeViktor Shlapakov2015-02-252-11/+71
* | Merge branch 'vshlapakov-feature-async-threading'Dana Powers2015-03-081-0/+44
|\ \
| * | Returned original tests, rm dirty flag, name fixesViktor Shlapakov2015-02-251-0/+44
* | | Merge pull request #296 from ecanzonieri/validate_consumer_offsetDana Powers2015-03-021-1/+43
|\ \ \ | |_|/ |/| |
| * | Retry failed partitions and add integration testsEnrico Canzonieri2015-01-261-1/+43
* | | 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
View Lorry Controller Status