summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
...
| * | Fix offset increments:Omar Ghishan2014-01-151-16/+17
* | | Merge pull request #107 from rdiomar/fix_default_timeoutsMarc Labbé2014-01-162-3/+13
|\ \ \
| * | | Change default socket timeout to 120 seconds in both the client and connectionOmar Ghishan2014-01-162-5/+10
| * | | Make the default connection timeout NoneOmar Ghishan2014-01-161-1/+6
| |/ /
* | | Merge pull request #98 from waliaashish85/devOmar2014-01-161-4/+2
|\ \ \
| * | | Deleting client_id from offset commit and fetch response as per Kafka trunk codeAshish Walia2014-01-131-2/+0
| * | | Syncing offset commit and fetch api keys with Kafka trunk codeAshish Walia2014-01-131-2/+2
* | | | Merge branch 'repr' of https://github.com/mahendra/kafka-python into mahendra...mrtheb2014-01-144-1/+18
|\ \ \ \ | |_|/ / |/| | |
| * | | Add proper string representations for each classMahendra M2013-10-084-2/+19
* | | | Merge pull request #100 from cosbynator/no_infinite_loops_realOmar2014-01-144-95/+125
|\ \ \ \
| * | | | Throw KafkaUnavailableError when no brokers availableThomas Dimson2014-01-132-2/+6
| * | | | Exception hierarchy, invalidate more md on errorsThomas Dimson2014-01-134-95/+121
* | | | | remove zero length field name in format string, to work in Python 2.6Vadim Graboys2014-01-131-1/+1
|/ / / /
* | | | Merge pull request #88 from rdiomar/rdiomar_changesOmar2014-01-135-190/+216
|\ \ \ \ | |_|/ / |/| | |
| * | | Change log.error() back to log.exception()Omar Ghishan2014-01-082-8/+8
| * | | Change BufferUnderflowError to ConnectionError in conn._read_bytes()Omar Ghishan2014-01-082-6/+4
| * | | 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
| * | | Remove unnecessary bracketsOmar Ghishan2014-01-061-2/+2
| * | | Add a limit to fetch buffer size, and actually retry requests when fetch size...Omar Ghishan2014-01-061-37/+58
| * | | Fix client error handlingOmar Ghishan2014-01-061-5/+17
| * | | Raise a ConnectionError when a socket.error is raised when receiving dataOmar Ghishan2014-01-062-10/+14
| * | | Fix seek offset deltasOmar Ghishan2014-01-061-6/+0
| * | | Add note about questionable error handling while decoding messages.Omar Ghishan2014-01-061-0/+8
| * | | Add and fix comments to protocol.pyOmar Ghishan2014-01-061-6/+10
| * | | Add comments and maintain 80 character line limitOmar Ghishan2014-01-061-7/+23
| * | | Add iter_timeout option to SimpleConsumer. If not None, it causes the iterato...Omar Ghishan2014-01-061-6/+22
| * | | Add buffer_size param description to docstring Omar Ghishan2014-01-061-1/+2
| * | | Remove SimpleConsumer queue size limit since it can cause the iteratorOmar Ghishan2014-01-061-1/+1
| * | | SimpleConsumer flow changes:Omar Ghishan2014-01-061-112/+70
| * | | Reset consumer fields to original values rather than defaults in FetchContextOmar Ghishan2014-01-061-3/+5
| * | | Allow None timeout in FetchContext even if block is FalseOmar Ghishan2014-01-061-4/+4
| * | | * Guarantee reading the expected number of bytes from the socket every timeOmar Ghishan2014-01-063-32/+30
| * | | Read the correct number of bytes from kafka.Omar Ghishan2014-01-061-3/+2
| * | | Allow customizing socket timeouts.Omar Ghishan2014-01-062-5/+6
* | | | Merge pull request #66 from jcrobak/fix-import-collisionDavid Arthur2014-01-083-0/+6
|\ \ \ \ | |/ / / |/| | |
| * | | Enable absolute imports for modules using Queue.Joe Crobak2013-10-213-0/+6
| | |/ | |/|
* | | Merge pull request #84 from nieksand/simpler_timeoutsDavid Arthur2013-12-281-3/+3
|\ \ \
| * | | Replaced _send_upstream datetime logic with simpler time().Niek Sanders2013-12-251-3/+3
* | | | reduce memory copies when consuming kafka responsesEvan Klitzke2013-12-251-5/+2
|/ / /
* | | allow for timeout to be None in SimpleConsumer.get_messagesZack Dever2013-12-121-1/+2
|/ /
* | Ensure that multiprocess consumer works in windowsMahendra M2013-10-081-53/+63
|/
* Merge branch 'master' into prod-windowsMahendra M2013-10-084-19/+49
|\
| * make changes to be more fault tolerant: clean up connections, brokers, failed...Jim Lim2013-10-044-19/+49
* | Ensure that async producer works in windows. Fixes #46Mahendra M2013-10-073-51/+87
|/
* Test fixes after flake8 runmrtheb2013-10-031-1/+2
* flake8 pass (pep8 and pyflakes)mrtheb2013-10-036-80/+97
* remove unused exception instance variablesVetoshkin Nikita2013-10-032-2/+2
* use NotImplementedError instead of NotImplementedErrorVetoshkin Nikita2013-10-031-1/+1
View Lorry Controller Status