summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
* 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
| * | Fix test_conn tests wrt _dirty / _sockDana Powers2014-08-191-9/+4
| * | 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
| * | Remove unused imports from test/test_conn.pyDana Powers2014-08-191-2/+0
| * | Implement last of the skipped test_conn.py testsDana Powers2014-08-191-2/+18
| * | Implement a few more skipped tests in test/test_conn.pyDana Powers2014-08-191-4/+19
| * | Move common connection testing code to setUp methodDana Powers2014-08-191-98/+45
| * | Implementing more skipped connection tests (send and recv)Dana Powers2014-08-191-6/+82
| * | Cleanup some connection tests in test/test_conn.pyDana Powers2014-08-191-14/+11
| * | socket.sendall should always raise an exception on error; remove extra return...Dana Powers2014-08-191-6/+7
| * | Improve KafkaConnection testing: mock socket.create_connection; add tests for...Dana Powers2014-08-191-8/+95
| * | 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-223-15/+39
|\ \ \
| * | | Fix write_int and write_short type validationMatthew L Daniel2014-08-221-0/+6
| * | | PEP8 fixesMatthew L Daniel2014-08-221-1/+2
| * | | Failing test for write_int and write_shortMatthew L Daniel2014-08-221-0/+16
| * | | PEP8 fixesMatthew L Daniel2014-08-221-12/+11
| * | | Correctly declare unittest2 dependencyMatthew L Daniel2014-08-221-2/+4
* | | | Merge pull request #194 from dpkp/kafka_timeout_errorDana Powers2014-08-223-3/+18
|\ \ \ \
| * | | | Add KafkaTimeoutError (used by client.ensure_topic_exists) and add a testDana Powers2014-08-143-3/+18
* | | | | Add TravisCI config for auto deploymentDavid Arthur2014-08-224-9/+24
| |/ / / |/| | |
* | | | Change TravisCI badge to reflect master branchDavid Arthur2014-08-211-1/+1
* | | | Tell Travis to build release-* branches as well as masterDavid Arthur2014-08-211-0/+5
* | | | Adding IRC to READMEDavid Arthur2014-08-211-1/+3
| |/ / |/| |
* | | Add apt-get install libsnappy-dev instructions to READMEDana Powers2014-08-141-6/+13
|/ /
* | Merge pull request #193 from dpkp/test_apache_binary_releaseMark Roberts2014-08-1418-62/+475
|\ \
View Lorry Controller Status