summaryrefslogtreecommitdiff
path: root/test
Commit message (Collapse)AuthorAgeFilesLines
...
* Dump fixture logs on OffsetResponse error during producer integrationDana Powers2015-06-081-3/+9
| | | | | tests. This is intended to help debug an intermittent failure that requires server logs.
* Retry with shorter 5sec timeout when trying to open() fixturesDana Powers2015-06-082-7/+14
| | | | | - this is intended to reduce flapping tests caused by intermittent - fixture startup issues on travis-ci
* Add unit tests for SimpleConsumer error handlingDana Powers2015-06-081-1/+74
|
* Merge pull request #380 from dpkp/multiprocess_consumer_partitionsDana Powers2015-06-081-2/+11
|\ | | | | Support optional partitions kwarg in MultiProcessConsumer
| * Support optional partitions kwarg in MultiProcessConsumerDana Powers2015-05-171-2/+11
| |
* | Merge pull request #379 from dpkp/deprecate_keyed_producer_sendDana Powers2015-06-081-10/+10
|\ \ | | | | | | Deprecate KeyedProducer.send in favor of send_messages
| * | Deprecate KeyedProducer.send in favor of send_messages -- keep interface ↵Dana Powers2015-05-171-10/+10
| |/ | | | | | | consistent
* | try to fix uncaught FailedPayloadsErrorreAsOn20102015-06-091-0/+8
| |
* | Respawn crashed services in test/service.py, rather than raise RuntimeErrorDana Powers2015-06-071-12/+26
| |
* | Deprecate async producer batch_send kwarg -- use 'async' insteadDana Powers2015-06-062-19/+2
| |
* | Encode random_message strings to bytes in test_failover_integrationDana Powers2015-06-061-1/+2
| |
* | Small hanging indent style nits in some producer integration testsDana Powers2015-06-061-4/+8
| |
* | Sleep for 500ms before retrying consumer pending call in testsDana Powers2015-06-061-0/+1
| |
* | test_batched_simple_producer__triggers_by_message should wait for producer ↵Dana Powers2015-06-061-0/+10
| | | | | | | | queue to drain before testing messages were sent
* | Include message number in sent message value in _send_random_messageDana Powers2015-06-061-1/+1
| |
* | add option to check for at-least-once message delivery in failover testsDana Powers2015-06-061-6/+12
| |
* | Reenable test_switch_leader_asyncDana Powers2015-06-061-7/+13
| |
* | FailedPayloadsError now only has a single payload; use .payload attributeDana Powers2015-06-061-2/+2
| | | | | | | | .failed_payloads attribute has been removed.
* | 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
| | | | | | | | - previously this would simply drop one of the payloads
* | 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
| | | | | | | | | | | | | | | | | | | | - send_producer_request with fail_on_error=False to retry failed reqs only - using an internal dict with with namedtuple keys for retry counters - refresh metadata on refresh_error irrespective to retries options - removed infinite retries (retry_options.limit=None) as an over-feature - separate producer init args for retries options (limit,backoff,on_timeouts) - AsyncProducerQueueFull returns a list of failed messages - producer tests improved thanks to @rogaha and @toli
* | 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 commit offsets in base consumer unless group is None
| * Fetch previously committed offsets in base consumer class so long asDana Powers2015-03-302-2/+5
| | | | | | | | | | | | | | | | 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.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
| | | | | | | | Tweak MP Consumer test to use iterator
* | Merge pull request #355 from dpkp/correlation_id_moduloDana Powers2015-03-301-0/+8
|\ \ | |/ |/| correlation_id modulo
| * 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
|\ | | | | Using additional params for MP consumer child process
| * 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 mode
| * Correct message keys for async batching modeViktor Shlapakov2015-02-252-11/+71
| |
* | Merge branch 'vshlapakov-feature-async-threading'Dana Powers2015-03-081-0/+44
|\ \ | | | | | | | | | | | | | | | | | | PR 330: Threading for async batching Conflicts: kafka/producer/base.py
| * | 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
|\ \ \ | |_|/ |/| | Validate consumer offset in SimpleConsumer
| * | Retry failed partitions and add integration testsEnrico Canzonieri2015-01-261-1/+43
| | |
View Lorry Controller Status