summaryrefslogtreecommitdiff
path: root/kafka/producer/simple.py
Commit message (Expand)AuthorAgeFilesLines
* Remove SimpleClient, Producer, Consumer, Unittest (#1196)Jeff Widman2019-10-111-54/+0
* Be explicit with tuples for %s formattingJeff Widman2018-11-181-1/+1
* Vendor `six` consistentlyJeff Widman2018-10-221-2/+2
* Change SimpleProducer to use async_send (async is reserved in py37) (#1454)Dana Powers2018-03-231-1/+1
* use absolute imports everywhere (#1362)Kevin Tindall2018-02-061-1/+1
* Vendor six 1.10.0sixDana Powers2016-08-011-1/+1
* Remove unused importskafka-3318Dana Powers2016-04-051-1/+0
* Merge branch '0.9'Dana Powers2016-01-071-3/+0
|\
| * Drop kafka_bytestringDana Powers2015-12-101-3/+0
* | Handle new topic creation / LeaderNotAvailableError in initial SimpleProducer...Dana Powers2015-12-161-1/+1
|/
* Dont maintain all producer args / kwargs in subclass __init__ and docstrings ...Dana Powers2015-06-081-48/+14
* Deprecate async producer batch_send kwarg -- use 'async' insteadDana Powers2015-06-061-2/+2
* Use separate module loggers instead of a single 'kafka' loggerDana Powers2015-06-061-1/+1
* Improve async producer code: logic and style fixesViktor Shlapakov2015-06-031-4/+8
* Fix names for async retries opts, add timeout for putViktor Shlapakov2015-06-031-3/+8
* Improved retry logicViktor Shlapakov2015-06-031-6/+3
* Retries for async batchingViktor Shlapakov2015-06-031-3/+8
* Just encode to bytes if it isn't bytes.John Anderson2015-01-241-2/+4
* Alert if the topic is not sent as bytesJohn Anderson2015-01-231-0/+4
* Merge pull request #282 from wedaly/sphinx-api-docsDana Powers2015-01-231-14/+16
|\
| * Add Sphinx API docsWill Daly2015-01-151-14/+16
* | Randomize start by default for SimpleProducerAlex Couture-Beil2015-01-091-1/+1
|/
* Separate consumers/producers/partitionersDana Powers2014-09-101-0/+73