summaryrefslogtreecommitdiff
path: root/kafka/producer.py
Commit message (Expand)AuthorAgeFilesLines
* Separate consumers/producers/partitionersDana Powers2014-09-101-319/+0
* Merge pull request #223 from dpkp/metadata_refactorDana Powers2014-09-081-10/+9
|\
| * Refactor internal metadata dicts in KafkaClientDana Powers2014-09-011-10/+9
* | Merge pull request #227 from wizzat-feature/py3Dana Powers2014-09-071-5/+11
|\ \
| * | Bytes in self.msg()Bruno Renié2014-09-031-1/+1
| * | Use built-in next()Bruno Renié2014-09-031-2/+2
| * | Make all unit tests pass on py3.3/3.4Bruno Renié2014-09-031-4/+10
| |/
* | Change message type requirement from str to bytes for clarity and prep for py...Dana Powers2014-09-041-5/+5
|/
* Add warnings to README, docstring, and logging that async producer does not r...Dana Powers2014-08-261-0/+6
* Raise TypeError in kafka.producer.send_messages if any msg is not a str (or s...Dana Powers2014-08-261-0/+21
* Handle New Topic CreationMark Roberts2014-05-221-2/+5
* Improve error handling and tests w.r.t. codecsPatrick Lucas2014-05-071-20/+9
* Merge branch 'teach_producers_about_compression' into producer_compressionMark Roberts2014-05-071-9/+33
|\
| * Add 'codec' parameter to ProducerPatrick Lucas2014-05-031-9/+33
* | added random_start param to SimpleProducer to enable/disable randomization of...Alex Couture-Beil2014-04-011-4/+11
* | Changed randomization to simply randomize the initial starting partition of t...Alex Couture-Beil2014-04-011-3/+7
* | Modified SimpleProducer to randomize the initial round robin orderingAlex Couture-Beil2014-03-111-1/+4
|/
* Use TopicAndPartition when producing async messagesOmar Ghishan2014-01-271-8/+11
* Make producers take a topic argument at send rather than init timeOmar Ghishan2014-01-231-34/+40
* Merge branch 'repr' of https://github.com/mahendra/kafka-python into mahendra...mrtheb2014-01-141-0/+6
|\
| * Add proper string representations for each classMahendra M2013-10-081-0/+6
* | Exception hierarchy, invalidate more md on errorsThomas Dimson2014-01-131-8/+7
* | Merge pull request #88 from rdiomar/rdiomar_changesOmar2014-01-131-3/+3
|\ \
| * | Change log.error() back to log.exception()Omar Ghishan2014-01-081-5/+5
| * | Raise a ConnectionError when a socket.error is raised when receiving dataOmar Ghishan2014-01-061-3/+3
* | | Merge pull request #66 from jcrobak/fix-import-collisionDavid Arthur2014-01-081-0/+2
|\ \ \ | |/ / |/| |
| * | Enable absolute imports for modules using Queue.Joe Crobak2013-10-211-0/+2
| |/
* | Replaced _send_upstream datetime logic with simpler time().Niek Sanders2013-12-251-3/+3
|/
* Merge branch 'master' into prod-windowsMahendra M2013-10-081-3/+8
|\
| * make changes to be more fault tolerant: clean up connections, brokers, failed...Jim Lim2013-10-041-3/+8
* | Ensure that async producer works in windows. Fixes #46Mahendra M2013-10-071-49/+63
|/
* remove unused exception instance variablesVetoshkin Nikita2013-10-031-1/+1
* Test cases for new producerMahendra M2013-06-271-1/+1
* Optimize sending of batch messagesMahendra M2013-06-261-6/+9
* Got batched mode to work properlyMahendra M2013-06-261-59/+48
* Update README with examplesMahendra M2013-06-261-1/+1
* Add support for batched message sendMahendra M2013-06-261-9/+100
* Make the default case as 'ack on local write'Mahendra M2013-06-201-3/+3
* Fix import errorsMahendra M2013-06-201-3/+5
* Add ack support for synchronous producerMahendra M2013-06-201-10/+39
* Merge branch 'master' into asyncproducerMahendra M2013-06-131-0/+34
|\
| * Fix bugs and testingMahendra M2013-06-131-2/+2
| * Implement support for Keyed producerMahendra M2013-06-131-0/+32
* | Support for async producerMahendra M2013-06-131-8/+57
|/
* PEP8-ify most of the filesMahendra M2013-05-291-1/+3
* Bring acks and timeout down to the clientDavid Arthur2013-04-021-2/+2
* Refactoring a bit, cleanup for 0.8David Arthur2013-04-021-2/+3
* Big code re-orgDavid Arthur2013-04-021-0/+22
View Lorry Controller Status