summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
* Fix test errors related to mocksMark Roberts2014-09-032-6/+10
* Merge branch 'feature/py3' of https://github.com/brutasse/kafka-python into f...Mark Roberts2014-09-030-0/+0
|\
| * Fix more tests, only multiprocessing consumer ones remainingBruno Renié2014-08-298-23/+39
| * Bytes in self.msg()Bruno Renié2014-08-292-2/+2
| * Use built-in next()Bruno Renié2014-08-292-3/+3
| * Cross-python iteritemsBruno Renié2014-08-291-1/+3
| * More bytes topicsBruno Renié2014-08-292-2/+2
| * Encode topic directlyBruno Renié2014-08-291-1/+2
| * Fix bytes interpolationBruno Renié2014-08-291-1/+1
| * Topic in bytesBruno Renié2014-08-281-1/+1
| * client_id in bytesBruno Renié2014-08-281-1/+1
| * Fix stderr captureBruno Renié2014-08-281-1/+1
| * Fix log capture on py3Bruno Renié2014-08-281-1/+1
| * Make all unit tests pass on py3.3/3.4Bruno Renié2014-08-2822-272/+350
| * Use base unittest or unittest2 depending on python versionBruno Renié2014-08-2813-30/+43
* | Fix more tests, only multiprocessing consumer ones remainingBruno Renié2014-09-038-23/+39
* | Bytes in self.msg()Bruno Renié2014-09-032-2/+2
* | Use built-in next()Bruno Renié2014-09-032-3/+3
* | Cross-python iteritemsBruno Renié2014-09-031-1/+3
* | More bytes topicsBruno Renié2014-09-032-2/+2
* | Encode topic directlyBruno Renié2014-09-031-1/+2
* | Fix bytes interpolationBruno Renié2014-09-031-1/+1
* | Topic in bytesBruno Renié2014-09-031-1/+1
* | client_id in bytesBruno Renié2014-09-031-1/+1
* | Fix stderr captureBruno Renié2014-09-031-1/+1
* | Fix log capture on py3Bruno Renié2014-09-031-1/+1
* | Make all unit tests pass on py3.3/3.4Bruno Renié2014-09-0322-271/+349
* | Use base unittest or unittest2 depending on python versionBruno Renié2014-09-0313-30/+43
* | Merge pull request #216 from zever/nit-incorrect-except-formatDana Powers2014-09-011-1/+1
|\ \ | |/ |/|
| * just fixing a silly except formatting mistakeZack Dever2014-08-291-1/+1
|/
* Version to 0.9.2 and Changelog (with some backstory)v0.9.2Dana Powers2014-08-273-6/+41
* Fixup producer failover tests to avoid consumer message count flapDana Powers2014-08-271-7/+8
* Merge pull request #213 from dpkp/improve_failover_testsDana Powers2014-08-273-46/+76
|\
| * Add warnings to README, docstring, and logging that async producer does not r...Dana Powers2014-08-262-1/+9
| * Improve leader failover tests; note that async produce failover is broken -- ...Dana Powers2014-08-261-45/+67
* | Add link to kafka-clients google-group on READMEDana Powers2014-08-261-1/+4
* | 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
* | | Add a test for Issue #135 (Spurious ConsumerFetchSizeTooSmall error)Dana Powers2014-08-261-0/+19
| |/ |/|
* | Merge pull request #208 from dpkp/add_pylint_to_tox_iniDana Powers2014-08-2610-58/+54
|\ \
| * | Add pylint to tox.ini; test both kafka and test; default to error-checking on...Dana Powers2014-08-2510-58/+54
* | | Merge pull request #211 from dpkp/str_only_produce_msgsDana Powers2014-08-263-0/+59
|\ \ \
| * | | Add producer unit test (test/test_producer.py); check supported types in send...Dana Powers2014-08-261-0/+31
| * | | Raise TypeError in kafka.producer.send_messages if any msg is not a str (or s...Dana Powers2014-08-262-0/+28
|/ / /
* | | Add test timers via nose-timer plugin; list the 10 slowest by defaultDana Powers2014-08-261-1/+2
* | | Merge pull request #177 from zever/fetch-last-known-offsetsDana Powers2014-08-251-10/+17
|\ \ \ | |/ / |/| |
| * | 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-222-40/+177
|\ \
| * | Add a mock to sock.recv() in the test_conn setUp method. Returns 2 packet pa...Dana Powers2014-08-191-61/+25
View Lorry Controller Status