summaryrefslogtreecommitdiff
path: root/kafka/conn.py
Commit message (Expand)AuthorAgeFilesLines
...
| * | 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
* Merge branch 'issue-35'David Arthur2013-07-261-0/+9
|\
| * Re-init the sockets in the new processMahendra M2013-06-271-0/+9
* | Make the default case as 'ack on local write'Mahendra M2013-06-201-1/+1
|/
* Fix auto-commit issues with multi-threadingMahendra M2013-06-031-1/+2
* Adding a debug statementDavid Arthur2013-05-281-1/+2
* Update kafka-src to latest 0.8David Arthur2013-04-021-1/+2
* Big code re-orgDavid Arthur2013-04-021-0/+85