summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
* Fix test errors related to mocksMark Roberts2014-09-031-3/+4
* Fix more tests, only multiprocessing consumer ones remainingBruno Renié2014-09-032-3/+7
* Bytes in self.msg()Bruno Renié2014-09-031-1/+1
* Use built-in next()Bruno Renié2014-09-032-3/+3
* Cross-python iteritemsBruno Renié2014-09-031-1/+3
* client_id in bytesBruno Renié2014-09-031-1/+1
* Make all unit tests pass on py3.3/3.4Bruno Renié2014-09-037-29/+66
* Merge pull request #213 from dpkp/improve_failover_testsDana Powers2014-08-271-0/+6
|\
| * Add warnings to README, docstring, and logging that async producer does not r...Dana Powers2014-08-261-0/+6
* | Merge pull request #136 from DataDog/fix-multifetch-buffer-sizeDana Powers2014-08-261-12/+14
|\ \ | |/ |/|
| * fix consumer retry logic (fixes #135)Carlo Cabanilla2014-02-281-12/+14
* | Merge pull request #208 from dpkp/add_pylint_to_tox_iniDana Powers2014-08-262-4/+4
|\ \
| * | Add pylint to tox.ini; test both kafka and test; default to error-checking on...Dana Powers2014-08-252-4/+4
* | | Raise TypeError in kafka.producer.send_messages if any msg is not a str (or s...Dana Powers2014-08-261-0/+21
* | | also reset `self.fetch_offsets` in `fetch_last_known_offsets`Zack Dever2014-08-251-0/+1
* | | Move fetching last known offset logic to a stand alone function.Zack Dever2014-08-251-10/+16
|/ /
* | Merge pull request #196 from dpkp/reinit_connection_errorDana Powers2014-08-221-18/+60
|\ \
| * | Improve docstrings in kafka.connDana Powers2014-08-191-4/+14
| * | Shutdown socket before closing in kafka.connDana Powers2014-08-191-0/+9
| * | Remove duplicate error handling blocks by moving empty response check into tr...Dana Powers2014-08-191-4/+8
| * | Remove self._dirty and check self._sock instead in kafka.connDana Powers2014-08-191-6/+11
| * | socket.sendall should always raise an exception on error; remove extra return...Dana Powers2014-08-191-6/+7
| * | Add some more debug logging to KafkaConnectionDana Powers2014-08-191-0/+7
| * | Initialized _dirty in KafkaConnection __init__() and set _sock to None in clo...Dana Powers2014-08-171-2/+4
| * | Call _raise_connection_error in KafkaConnection.reinit() if socket connection...Dana Powers2014-08-171-2/+6
* | | Merge pull request #204 from mdaniel/better-type-errorsDana Powers2014-08-221-1/+8
|\ \ \
| * | | Fix write_int and write_short type validationMatthew L Daniel2014-08-221-0/+6
| * | | PEP8 fixesMatthew L Daniel2014-08-221-1/+2
| |/ /
* | | Merge pull request #194 from dpkp/kafka_timeout_errorDana Powers2014-08-222-3/+7
|\ \ \
| * | | Add KafkaTimeoutError (used by client.ensure_topic_exists) and add a testDana Powers2014-08-142-3/+7
| |/ /
* | | Add TravisCI config for auto deploymentDavid Arthur2014-08-221-1/+1
|/ /
* | Merge pull request #174 from wizzat/new_topicDana Powers2014-08-102-11/+24
|\ \
| * | Handle New Topic CreationMark Roberts2014-05-222-11/+24
* | | Set module version in separate VERSION fileDana Powers2014-08-101-1/+3
|/ /
* | Merge pull request #166 from patricklucas/teach_producers_about_compressionDana Powers2014-05-193-22/+59
|\ \
| * | Improve error handling and tests w.r.t. codecsPatrick Lucas2014-05-073-21/+33
| * | Merge branch 'teach_producers_about_compression' into producer_compressionMark Roberts2014-05-072-20/+45
| |\ \
| | * | Add 'codec' parameter to ProducerPatrick Lucas2014-05-032-20/+45
* | | | Support IPv6 hosts and networksAlexey Borzenkov2014-05-091-3/+1
|/ / /
* | | Merge branch 'master' into add_testsMark Roberts2014-05-061-1/+15
|\ \ \
| * \ \ Merge pull request #139 from alexcb/masterDana Powers2014-05-061-1/+15
| |\ \ \
| | * | | 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
| * | | | Fix lack of timeout support in KafkaClient and KafkaConnectionmaciejkula2014-04-162-2/+2
| | |/ / | |/| |
* | | | Attempt to fix travis build. Decrease complexity of service.py in favor of in...Mark Roberts2014-05-064-8/+12
* | | | Make commit() check for errors instead of simply assert no errorMark Roberts2014-04-301-1/+1
* | | | Make BrokerRequestError a base class, make subclasses for each broker errorMark Roberts2014-04-303-53/+113
* | | | Various fixesMark Roberts2014-04-252-2/+9
* | | | Fix last remaining test by making autocommit more intuitiveMark Roberts2014-04-241-1/+1
View Lorry Controller Status