summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
...
* | | | KafkaClient should try/except ConnnectionError when calling _get_connDana Powers2015-06-061-2/+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-062-4/+4
| | | | | | | | | | | | | | | | .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-063-1/+10
| | | | | | | | | | | | | | | | - previously this would simply drop one of the payloads
* | | | Module loggers in test/fixtures and test/serviceDana Powers2015-06-062-27/+35
| | | |
* | | | Use separate module loggers instead of a single 'kafka' loggerDana Powers2015-06-069-9/+17
| |_|/ |/| |
* | | Fix import error in kafka/producer/base.pyDana Powers2015-06-061-1/+1
| | |
* | | Merge pull request #387 from dpkp/no_runtime_version_checkDana Powers2015-06-045-8/+5
|\ \ \ | | | | | | | | Dont get __version__ from pkg_resources
| * | | Set __version__ string in kafka/version.pyDana Powers2015-06-045-8/+5
|/ / /
* | | Merge pull request #331 from vshlapakov/feature-producer-retriesDana Powers2015-06-046-29/+296
|\ \ \ | |_|/ |/| | Async producer retries for failed messages
| * | Check response.error for async producerViktor Shlapakov2015-06-033-21/+27
| | |
| * | Async producer: py2.6 backward compatibility fixViktor Shlapakov2015-06-031-2/+2
| | |
| * | Improve async producer code: logic and style fixesViktor Shlapakov2015-06-035-76/+75
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - 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
| | |
| * | Change backoff message log levelViktor Shlapakov2015-06-031-1/+1
| | |
| * | Fix async producer queue put argumentsViktor Shlapakov2015-06-031-2/+4
| | |
| * | Fix names for async retries opts, add timeout for putViktor Shlapakov2015-06-034-20/+34
| | |
| * | Simplification of retry logicViktor Shlapakov2015-06-032-31/+29
| | |
| * | Fix small issues with names/testsViktor Shlapakov2015-06-033-16/+16
| | |
| * | async queue: refactored code; add one more testEduard Iskandarov2015-06-032-4/+23
| | |
| * | add producer send batch queue overfilled testИскандаров Эдуард2015-06-032-2/+24
| | |
| * | Disable retry on timeouts by default (old behaviour)Viktor Shlapakov2015-06-031-1/+1
| | |
| * | Clean and simplify retry logicViktor Shlapakov2015-06-033-63/+54
| | |
| * | Arg fixes for base/keyed producersViktor Shlapakov2015-06-032-4/+2
| | |
| * | Improved retry logicViktor Shlapakov2015-06-035-34/+76
| | |
| * | Fixed tests and other issues after rebaseViktor Shlapakov2015-06-033-32/+20
| | |
| * | Returned default behaviour with no retriesViktor Shlapakov2015-06-031-1/+1
| | |
| * | Fix: check failed reqs to retry only for positive limitViktor Shlapakov2015-06-031-3/+3
| | |
| * | Fixed compatible issues with testsViktor Shlapakov2015-06-032-15/+16
| | |
| * | Producer _send_upstream fixes, added tests for retriesViktor Shlapakov2015-06-032-6/+157
| | |
| * | Fixed base producer importsViktor Shlapakov2015-06-031-1/+2
| | |
| * | Retries for async batchingViktor Shlapakov2015-06-034-15/+50
|/ /
* | Merge pull request #342 from wting/fix_consumer_falsinessDana Powers2015-05-171-4/+4
|\ \ | |/ |/| | | Remove Consumer falsiness.
| * Check vs None directly.William Ting2015-05-171-4/+4
|/
* Merge pull request #376 from hellais/fix/offsetDana Powers2015-05-141-1/+1
|\ | | | | Fix calling of _offsets
| * Fix calling of _offsetsArturo Filastò2015-05-141-1/+1
|/ | | | | | | | Previously you would see this error: ``` self.offsets._fetch[(topic, partition)], AttributeError: 'function' object has no attribute '_fetch' ```
* Merge pull request #367 from dpkp/clean_metadata_refreshDana Powers2015-04-121-13/+14
|\ | | | | Clear local metadata cache before refresh in client.load_metadata_for_topics()
| * Update debug log messages in client.load_metadata_for_topicsDana Powers2015-04-121-2/+2
| |
| * clean local metadata before requesting refresh in load_metadata_for_topics()Dana Powers2015-04-121-2/+7
| |
| * Simplify client.reset_topic_metadataDana Powers2015-04-121-9/+5
| |
* | Merge pull request #366 from dpkp/failed_payloadsDana Powers2015-04-121-79/+77
|\ \ | |/ |/| Refactor client request/response handling to support better retries
| * Improve send_produce_request docstringDana Powers2015-04-061-6/+17
| |
| * Add debug logging for all broker-aware requests/responsesDana Powers2015-04-061-0/+3
| |
| * Refactor KafkaClient._send_broker_aware_request to return a list of responsesDana Powers2015-04-061-73/+57
| | | | | | | | | | | | and include individual (unraised) FailedPayloadsError instances rather than always raising a FailedPayloadsError. This should allow producers to determine which payloads succeeded and which failed, specifically.
View Lorry Controller Status