| Commit message (Expand) | Author | Age | Files | Lines |
* | Catch ReplicaNotAvailableError in MetadataResponse -- per kafka-devs, this er... | Dana Powers | 2015-01-14 | 1 | -1/+6 |
* | Use six for py3 support in KafkaConsumer | Dana Powers | 2014-12-15 | 1 | -3/+3 |
* | Merge pull request #223 from dpkp/metadata_refactor | Dana Powers | 2014-09-08 | 1 | -63/+156 |
|\ |
|
| * | Add test for sending produce request to unknown topic w/o auto-creation | Dana Powers | 2014-09-01 | 1 | -2/+2 |
| * | Use standard exceptions in client._get_leader_for_partition() | Dana Powers | 2014-09-01 | 1 | -15/+28 |
| * | Raise UnknownTopicOrPartitionError immediately in ensure_topic_exists -- serv... | Dana Powers | 2014-09-01 | 1 | -0/+4 |
| * | load_metadata_for_topics should raise exceptions on explicit topic args | Dana Powers | 2014-09-01 | 1 | -12/+40 |
| * | Refactor internal metadata dicts in KafkaClient | Dana Powers | 2014-09-01 | 1 | -20/+56 |
| * | No more custom LeaderUnavailableError exception -- raise LeaderNotAvailableError | Dana Powers | 2014-09-01 | 1 | -3/+3 |
| * | Rearrange KafkaClient method order to group client metadata methods together | Dana Powers | 2014-09-01 | 1 | -18/+18 |
| * | Improve metadata protocol handling | Dana Powers | 2014-09-01 | 1 | -9/+21 |
* | | Fix test errors related to mocks | Mark Roberts | 2014-09-03 | 1 | -3/+4 |
* | | Fix more tests, only multiprocessing consumer ones remaining | Bruno Renié | 2014-09-03 | 1 | -3/+3 |
* | | client_id in bytes | Bruno Renié | 2014-09-03 | 1 | -1/+1 |
* | | Make all unit tests pass on py3.3/3.4 | Bruno Renié | 2014-09-03 | 1 | -1/+1 |
|/ |
|
* | Add pylint to tox.ini; test both kafka and test; default to error-checking on... | Dana Powers | 2014-08-25 | 1 | -1/+1 |
* | Add KafkaTimeoutError (used by client.ensure_topic_exists) and add a test | Dana Powers | 2014-08-14 | 1 | -3/+3 |
* | Handle New Topic Creation | Mark Roberts | 2014-05-22 | 1 | -9/+19 |
* | 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 |