| Commit message (Expand) | Author | Age | Files | Lines |
* | Attempt to fix travis build. Decrease complexity of service.py in favor of in... | Mark Roberts | 2014-05-06 | 1 | -2/+0 |
* | Make BrokerRequestError a base class, make subclasses for each broker error | Mark Roberts | 2014-04-30 | 1 | -19/+17 |
* | Refactor away _get_conn_for_broker. Fix bug in _get_conn | Mark Roberts | 2014-04-09 | 1 | -13/+6 |
* | Merge pull request #134 from wizzat/conn_refactorv0.9.0 | Dana Powers | 2014-03-21 | 1 | -3/+3 |
|\ |
|
| * | Merge branch 'master' into conn_refactor | Mark Roberts | 2014-03-18 | 1 | -3/+3 |
| |\ |
|
| * \ | Merge branch 'master' into conn_refactor | Mark Roberts | 2014-02-26 | 1 | -7/+18 |
| |\ \ |
|
| * | | | Minor refactor in conn.py, update version in __init__.py, add ErrorString | Mark Roberts | 2014-02-25 | 1 | -3/+3 |
* | | | | Merge branch 'master' into develop | mrtheb | 2014-03-17 | 1 | -9/+20 |
|\ \ \ \
| | |_|/
| |/| | |
|
| * | | | If a broker refuses the connection, try the next | stephenarmstrong | 2014-03-13 | 1 | -3/+3 |
| | |/
| |/| |
|
| * | | Support list (or comma-separated) of hosts (replaces host and port arguments) | mrtheb | 2014-02-09 | 1 | -6/+7 |
| * | | Merge branch 'master' into multihosts | mrtheb | 2014-01-31 | 1 | -91/+120 |
| |\ \
| | |/ |
|
| * | | Allow KafkaClient to take in a list of brokers for bootstrapping | Marc Labbe | 2013-11-14 | 1 | -14/+21 |
* | | | Changes based on comments by @rdiomar, plus added LeaderUnavailableError for ... | mrtheb | 2014-02-15 | 1 | -4/+7 |
* | | | check for broker None in send_broker_aware_request (added test for it) | mrtheb | 2014-01-31 | 1 | -5/+14 |
* | | | Handle cases for partition with leader=-1 (not defined) | Marc Labbe | 2014-01-31 | 1 | -6/+12 |
* | | | added mock | mrtheb | 2014-01-18 | 1 | -3/+4 |
| |/
|/| |
|
* | | Merge pull request #107 from rdiomar/fix_default_timeouts | Marc Labbé | 2014-01-16 | 1 | -2/+6 |
|\ \ |
|
| * | | Change default socket timeout to 120 seconds in both the client and connection | Omar Ghishan | 2014-01-16 | 1 | -2/+6 |
* | | | Merge branch 'repr' of https://github.com/mahendra/kafka-python into mahendra... | mrtheb | 2014-01-14 | 1 | -0/+3 |
|\ \ \
| |/ /
|/| | |
|
| * | | Add proper string representations for each class | Mahendra M | 2013-10-08 | 1 | -1/+4 |
| |/ |
|
* | | Throw KafkaUnavailableError when no brokers available | Thomas Dimson | 2014-01-13 | 1 | -2/+2 |
* | | Exception hierarchy, invalidate more md on errors | Thomas Dimson | 2014-01-13 | 1 | -80/+88 |
* | | Change BufferUnderflowError to ConnectionError in conn._read_bytes() | Omar Ghishan | 2014-01-08 | 1 | -3/+2 |
* | | Fix client error handling | Omar Ghishan | 2014-01-06 | 1 | -5/+17 |
* | | * Guarantee reading the expected number of bytes from the socket every time | Omar Ghishan | 2014-01-06 | 1 | -4/+3 |
* | | Allow customizing socket timeouts. | Omar Ghishan | 2014-01-06 | 1 | -3/+4 |
|/ |
|
* | Merge branch 'master' into prod-windows | Mahendra M | 2013-10-08 | 1 | -6/+18 |
|\ |
|
| * | make changes to be more fault tolerant: clean up connections, brokers, failed... | Jim Lim | 2013-10-04 | 1 | -6/+18 |
* | | Ensure that async producer works in windows. Fixes #46 | Mahendra M | 2013-10-07 | 1 | -0/+11 |
|/ |
|
* | Test fixes after flake8 run | mrtheb | 2013-10-03 | 1 | -1/+2 |
* | flake8 pass (pep8 and pyflakes) | mrtheb | 2013-10-03 | 1 | -21/+20 |
* | style: fix camelCase variable names | Vetoshkin Nikita | 2013-10-03 | 1 | -3/+3 |
* | style: use triple quotes for docstrings | Vetoshkin Nikita | 2013-10-03 | 1 | -2/+6 |
* | style: fix whitespaces | Vetoshkin Nikita | 2013-10-03 | 1 | -1/+1 |
* | allow a client id to be passed to the client | Jim Lim | 2013-09-24 | 1 | -4/+5 |
* | Merge branch 'issue-35' | David Arthur | 2013-07-26 | 1 | -3/+11 |
|\ |
|
| * | Re-init the sockets in the new process | Mahendra M | 2013-06-27 | 1 | -0/+4 |
| * | Implement blocking get_messages for SimpleConsumer | Mahendra M | 2013-06-25 | 1 | -3/+7 |
* | | Make the default case as 'ack on local write' | Mahendra M | 2013-06-20 | 1 | -2/+11 |
|/ |
|
* | Fix bugs and testing | Mahendra M | 2013-06-13 | 1 | -0/+5 |
* | Finish making remaining files pep8 ready | Mahendra M | 2013-06-04 | 1 | -60/+109 |
* | Minor bug fixes | Mahendra M | 2013-05-29 | 1 | -0/+6 |
* | A few fixes for offset APIs in 0.8.1 | David Arthur | 2013-04-02 | 1 | -1/+1 |
* | Update kafka-src to latest trunk, enable 0.8.1 features | David Arthur | 2013-04-02 | 1 | -2/+0 |
* | Update kafka-src to latest 0.8 | David Arthur | 2013-04-02 | 1 | -1/+1 |
* | Bring acks and timeout down to the client | David Arthur | 2013-04-02 | 1 | -3/+3 |
* | Refactoring a bit, cleanup for 0.8 | David Arthur | 2013-04-02 | 1 | -131/+136 |
* | Big code re-org | David Arthur | 2013-04-02 | 1 | -641/+4 |
* | Some work on a simple consumer | David Arthur | 2013-04-02 | 1 | -4/+32 |
* | Started on a simple producer and consumer | David Arthur | 2013-04-02 | 1 | -6/+48 |