summaryrefslogtreecommitdiff
path: root/kafka/conn.py
Commit message (Expand)AuthorAgeFilesLines
* Merge pull request #227 from wizzat-feature/py3Dana Powers2014-09-071-4/+10
|\
| * Fix more tests, only multiprocessing consumer ones remainingBruno Renié2014-09-031-0/+4
| * Make all unit tests pass on py3.3/3.4Bruno Renié2014-09-031-4/+6
* | Minor import cleanupsDana Powers2014-09-041-1/+1
|/
* Add pylint to tox.ini; test both kafka and test; default to error-checking on...Dana Powers2014-08-251-3/+3
* 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
* Support IPv6 hosts and networksAlexey Borzenkov2014-05-091-3/+1
* Fix lack of timeout support in KafkaClient and KafkaConnectionmaciejkula2014-04-161-1/+1
* Merge branch 'master' into conn_refactorMark Roberts2014-03-181-2/+2
|\
| * Check against basestring instead of str in collect.hosts.Saulius Zemaitaitis2014-03-171-1/+1
| * nit: fixed misspellingZack Dever2014-03-031-1/+1
* | Merge branch 'master' into conn_refactorMark Roberts2014-02-261-1/+27
|\ \ | |/
| * clean up after comments from @rdiomarmrtheb2014-02-151-3/+5
| * Support list (or comma-separated) of hosts (replaces host and port arguments)mrtheb2014-02-091-1/+4
| * Merge branch 'master' into multihostsmrtheb2014-01-311-48/+45
| |\
| * | Allow KafkaClient to take in a list of brokers for bootstrappingMarc Labbe2013-11-141-7/+26
* | | Minor refactor in conn.py, update version in __init__.py, add ErrorStringMark Roberts2014-02-251-8/+11
| |/ |/|
* | Merge pull request #107 from rdiomar/fix_default_timeoutsMarc Labbé2014-01-161-1/+7
|\ \
| * | Change default socket timeout to 120 seconds in both the client and connectionOmar Ghishan2014-01-161-3/+4
| * | Make the default connection timeout NoneOmar Ghishan2014-01-161-1/+6
* | | Merge branch 'repr' of https://github.com/mahendra/kafka-python into mahendra...mrtheb2014-01-141-1/+1
|\ \ \ | |/ / |/| |
| * | Add proper string representations for each classMahendra M2013-10-081-1/+1
| |/
* | remove zero length field name in format string, to work in Python 2.6Vadim Graboys2014-01-131-1/+1
* | Change log.error() back to log.exception()Omar Ghishan2014-01-081-3/+3
* | Change BufferUnderflowError to ConnectionError in conn._read_bytes()Omar Ghishan2014-01-081-3/+2
* | Remove unnecessary methodOmar Ghishan2014-01-071-17/+8
* | Handle dirty flag in conn.recv()Omar Ghishan2014-01-071-1/+3
* | Use the same timeout when reinitializing a connectionOmar Ghishan2014-01-071-2/+3
* | Raise a ConnectionError when a socket.error is raised when receiving dataOmar Ghishan2014-01-061-7/+11
* | * Guarantee reading the expected number of bytes from the socket every timeOmar Ghishan2014-01-061-26/+22
* | Read the correct number of bytes from kafka.Omar Ghishan2014-01-061-3/+2
* | Allow customizing socket timeouts.Omar Ghishan2014-01-061-2/+2
* | reduce memory copies when consuming kafka responsesEvan Klitzke2013-12-251-5/+2
|/
* Merge branch 'master' into prod-windowsMahendra M2013-10-081-10/+18
|\
| * make changes to be more fault tolerant: clean up connections, brokers, failed...Jim Lim2013-10-041-10/+18
* | Ensure that async producer works in windows. Fixes #46Mahendra M2013-10-071-2/+13
|/
* flake8 pass (pep8 and pyflakes)mrtheb2013-10-031-6/+14
* don't forget to call superclass __init__Vetoshkin Nikita2013-10-031-0/+1
* style: fix camelCase variable names againVetoshkin Nikita2013-10-031-2/+2
* style: fix camelCase variable names once moreVetoshkin Nikita2013-10-031-3/+3
* style: fix camelCase variable namesVetoshkin Nikita2013-10-031-2/+2
* style: use triple quotes for docstringsVetoshkin Nikita2013-10-031-2/+6
* style: fix whitespacesVetoshkin Nikita2013-10-031-0/+2
View Lorry Controller Status