summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
...
* Add a few extra docstring comments about thread-safe clients/connectionsDana Powers2015-06-083-5/+12
* Dont maintain all producer args / kwargs in subclass __init__ and docstrings ...Dana Powers2015-06-082-91/+24
* Cleanup imports in kafka/client and kafka/consumerDana Powers2015-06-083-23/+21
* 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
* | SimpleConsumer should refresh metadata and retry on leadership changes; only ...Dana Powers2015-06-081-1/+4
* | Merge pull request #380 from dpkp/multiprocess_consumer_partitionsDana Powers2015-06-081-3/+7
|\ \
| * | Support optional partitions kwarg in MultiProcessConsumerDana Powers2015-05-171-3/+7
* | | Merge pull request #379 from dpkp/deprecate_keyed_producer_sendDana Powers2015-06-081-5/+6
|\ \ \
| * | | Deprecate KeyedProducer.send in favor of send_messages -- keep interface cons...Dana Powers2015-05-171-5/+6
* | | | try to fix uncaught FailedPayloadsErrorreAsOn20102015-06-092-1/+10
* | | | 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-063-26/+44
* | | | 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
* | | | KafkaClient should try/except ConnnectionError when calling _get_connDana Powers2015-06-061-2/+2
* | | | FailedPayloadsError now only has a single payload; use .payload attributeDana Powers2015-06-061-2/+2
* | | | Raise an error if we attempt to group duplicate topic-partition payloadsDana Powers2015-06-062-0/+5
* | | | 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
* | | Set __version__ string in kafka/version.pyDana Powers2015-06-042-3/+2
* | | Check response.error for async producerViktor Shlapakov2015-06-031-19/+24
* | | Async producer: py2.6 backward compatibility fixViktor Shlapakov2015-06-031-2/+2
* | | Improve async producer code: logic and style fixesViktor Shlapakov2015-06-034-43/+55
* | | 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-032-9/+11
* | | async queue: refactored code; add one more testEduard Iskandarov2015-06-031-2/+7
* | | add producer send batch queue overfilled testИскандаров Эдуард2015-06-031-1/+7
* | | Disable retry on timeouts by default (old behaviour)Viktor Shlapakov2015-06-031-1/+1
* | | Clean and simplify retry logicViktor Shlapakov2015-06-032-60/+49
* | | Arg fixes for base/keyed producersViktor Shlapakov2015-06-032-4/+2
* | | Improved retry logicViktor Shlapakov2015-06-034-31/+73
* | | Fixed tests and other issues after rebaseViktor Shlapakov2015-06-032-2/+1
* | | 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-031-3/+5
* | | Producer _send_upstream fixes, added tests for retriesViktor Shlapakov2015-06-031-6/+20
* | | Fixed base producer importsViktor Shlapakov2015-06-031-1/+2
* | | Retries for async batchingViktor Shlapakov2015-06-034-15/+50
| |/ |/|
View Lorry Controller Status