summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
...
* | Dump fixture logs on OffsetResponse error during producer integrationDana Powers2015-06-081-3/+9
* | Retry with shorter 5sec timeout when trying to open() fixturesDana Powers2015-06-082-7/+14
|/
* Merge pull request #389 from dpkp/task_done_key_errorDana Powers2015-06-081-2/+10
|\
| * KafkaConsumer.task_done - warn and skip messages from unrecognized topic-part...Dana Powers2015-06-061-2/+10
* | Merge pull request #393 from dpkp/simple_consumer_leader_changeDana Powers2015-06-082-2/+78
|\ \
| * | SimpleConsumer should refresh metadata and retry on leadership changes; only ...Dana Powers2015-06-081-1/+4
| * | Add unit tests for SimpleConsumer error handlingDana Powers2015-06-081-1/+74
|/ /
* | Merge pull request #380 from dpkp/multiprocess_consumer_partitionsDana Powers2015-06-082-5/+18
|\ \
| * | Support optional partitions kwarg in MultiProcessConsumerDana Powers2015-05-172-5/+18
* | | Merge pull request #379 from dpkp/deprecate_keyed_producer_sendDana Powers2015-06-083-17/+18
|\ \ \
| * | | Deprecate KeyedProducer.send in favor of send_messages -- keep interface cons...Dana Powers2015-05-173-17/+18
* | | | Merge pull request #392 from reAsOn2010/fix-uncaught-FailedPayloadsErrorDana Powers2015-06-083-1/+18
|\ \ \ \
| * | | | try to fix uncaught FailedPayloadsErrorreAsOn20102015-06-093-1/+18
|/ / / /
* | | | Respawn crashed services in test/service.py, rather than raise RuntimeErrorDana Powers2015-06-071-12/+26
* | | | Merge pull request #388 from dpkp/331_fixupsDana Powers2015-06-066-110/+180
|\ \ \ \
| * | | | Add async_stop_timeout parameter to tune how long to let the producerDana Powers2015-06-061-3/+26
| * | | | Dont stop async producer until all pending messages have been processedDana Powers2015-06-061-1/+1
| * | | | Update Producer class docstringDana Powers2015-06-061-4/+25
| * | | | Deprecate async producer batch_send kwarg -- use 'async' insteadDana Powers2015-06-066-46/+47
| * | | | Log retries and failed messages in async producer (configurable as full messa...Dana Powers2015-06-061-12/+24
| * | | | PR 331 fixup: do not attempt to get new messages if there are pending retriesDana Powers2015-06-061-4/+9
| * | | | PR 331 fixup: Rename reqs dict to request_triesDana Powers2015-06-061-9/+13
| * | | | PR 331 fixup: Dont need try/except when calling send_produce_requests with fa...Dana Powers2015-06-061-15/+16
| * | | | PR 331 fixup: log warnings on async producer backoff and metadata refreshDana Powers2015-06-061-1/+2
| * | | | PR 331 fixup: Support unlimited retries with async_retry_limit=NoneDana Powers2015-06-061-6/+8
| * | | | PR 331 fixup: fix _handle_error closureDana Powers2015-06-061-16/+17
| * | | | PR 331 fixup: Fix kafka.common imports from kafka.producer.base (one import b...Dana Powers2015-06-061-3/+2
|/ / / /
* | | | Encode random_message strings to bytes in test_failover_integrationDana Powers2015-06-061-1/+2
* | | | 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 qu...Dana Powers2015-06-061-0/+10
* | | | 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
* | | | 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
* | | | 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
|\ \ \
| * | | 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
|\ \ \ | |_|/ |/| |
| * | 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
| * | 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
View Lorry Controller Status