| Commit message (Expand) | Author | Age | Files | Lines |
* | Merge branch 'master' into add_tests | Mark Roberts | 2014-05-06 | 1 | -1/+15 |
|\ |
|
| * | Merge pull request #139 from alexcb/master | Dana Powers | 2014-05-06 | 1 | -1/+15 |
| |\ |
|
| | * | added random_start param to SimpleProducer to enable/disable randomization of... | Alex Couture-Beil | 2014-04-01 | 1 | -4/+11 |
| | * | Changed randomization to simply randomize the initial starting partition of t... | Alex Couture-Beil | 2014-04-01 | 1 | -3/+7 |
| | * | Modified SimpleProducer to randomize the initial round robin ordering | Alex Couture-Beil | 2014-03-11 | 1 | -1/+4 |
| * | | Fix lack of timeout support in KafkaClient and KafkaConnection | maciejkula | 2014-04-16 | 2 | -2/+2 |
* | | | Attempt to fix travis build. Decrease complexity of service.py in favor of in... | Mark Roberts | 2014-05-06 | 4 | -8/+12 |
* | | | Make commit() check for errors instead of simply assert no error | Mark Roberts | 2014-04-30 | 1 | -1/+1 |
* | | | Make BrokerRequestError a base class, make subclasses for each broker error | Mark Roberts | 2014-04-30 | 3 | -53/+113 |
* | | | Various fixes | Mark Roberts | 2014-04-25 | 2 | -2/+9 |
* | | | Fix last remaining test by making autocommit more intuitive | Mark Roberts | 2014-04-24 | 1 | -1/+1 |
* | | | Split out kafka version environments, default tox no longer runs any integrat... | Mark Roberts | 2014-04-23 | 1 | -11/+11 |
* | | | Fix bug in socket timeout per PR #161 by maciejkula, add test | Mark Roberts | 2014-04-19 | 1 | -1/+1 |
* | | | Split up and speed up producer based integration tests | Mark Roberts | 2014-04-17 | 2 | -1/+2 |
* | | | Refactor away _get_conn_for_broker. Fix bug in _get_conn | Mark Roberts | 2014-04-09 | 1 | -13/+6 |
* | | | Merge branch 'master' into add_tests | Mark Roberts | 2014-04-08 | 1 | -0/+4 |
|\ \ \
| |/ / |
|
| * | | Commit in seek if autocommit | Mark Roberts | 2014-03-27 | 1 | -1/+4 |
| * | | Make seek(); commit(); work without commit discarding the seek change | Mark Roberts | 2014-03-25 | 1 | -0/+1 |
* | | | Reinstate test_integrate, make test_protocol more explicit, create testutil | Mark Roberts | 2014-04-08 | 1 | -1/+1 |
* | | | Explicit testing of protocol errors. Make tests more explicit, and start wor... | Mark Roberts | 2014-04-08 | 2 | -4/+7 |
|/ / |
|
* | | Merge pull request #134 from wizzat/conn_refactorv0.9.0 | Dana Powers | 2014-03-21 | 3 | -26/+35 |
|\ \ |
|
| * \ | Merge branch 'master' into conn_refactor | Mark Roberts | 2014-03-18 | 2 | -5/+5 |
| |\ \ |
|
| * \ \ | Merge branch 'master' into conn_refactor | Mark Roberts | 2014-02-26 | 3 | -9/+46 |
| |\ \ \ |
|
| * | | | | Fix grammar in error string | Mark Roberts | 2014-02-25 | 1 | -1/+1 |
| * | | | | Minor refactor in conn.py, update version in __init__.py, add ErrorString | Mark Roberts | 2014-02-25 | 3 | -26/+35 |
* | | | | | Merge pull request #109 from mrtheb/develop | Dana Powers | 2014-03-21 | 2 | -10/+29 |
|\ \ \ \ \
| |_|_|/ /
|/| | | | |
|
| * | | | | Merge branch 'master' into develop | mrtheb | 2014-03-17 | 5 | -15/+144 |
| |\ \ \ \ |
|
| * | | | | | Changes based on comments by @rdiomar, plus added LeaderUnavailableError for ... | mrtheb | 2014-02-15 | 2 | -4/+11 |
| * | | | | | check for broker None in send_broker_aware_request (added test for it) | mrtheb | 2014-01-31 | 1 | -5/+14 |
| * | | | | | Merge branch 'master' into develop | mrtheb | 2014-01-31 | 2 | -74/+114 |
| |\ \ \ \ \ |
|
| * | | | | | | Handle cases for partition with leader=-1 (not defined) | Marc Labbe | 2014-01-31 | 2 | -10/+12 |
| * | | | | | | added mock | mrtheb | 2014-01-18 | 1 | -3/+4 |
* | | | | | | | Check against basestring instead of str in collect.hosts. | Saulius Zemaitaitis | 2014-03-17 | 1 | -1/+1 |
| |_|/ / / /
|/| | | | | |
|
* | | | | | | If a broker refuses the connection, try the next | stephenarmstrong | 2014-03-13 | 1 | -3/+3 |
| |_|_|_|/
|/| | | | |
|
* | | | | | nit: fixed misspelling | Zack Dever | 2014-03-03 | 1 | -1/+1 |
| |_|_|/
|/| | | |
|
* | | | | Merge pull request #122 from mrtheb/multihosts | Omar | 2014-02-26 | 3 | -9/+46 |
|\ \ \ \
| |_|_|/
|/| | | |
|
| * | | | clean up after comments from @rdiomar | mrtheb | 2014-02-15 | 1 | -3/+5 |
| * | | | Support list (or comma-separated) of hosts (replaces host and port arguments) | mrtheb | 2014-02-09 | 2 | -7/+11 |
| * | | | Merge branch 'master' into multihosts | mrtheb | 2014-01-31 | 7 | -341/+471 |
| |\ \ \
| | | |/
| | |/| |
|
| * | | | Allow KafkaClient to take in a list of brokers for bootstrapping | Marc Labbe | 2013-11-14 | 3 | -22/+48 |
* | | | | Fix version in __init__.py to match setup.py | David Arthur | 2014-02-25 | 1 | -1/+1 |
* | | | | Make it possible to read and write xerial snappy | Greg Bowyer | 2014-02-19 | 1 | -3/+95 |
| |/ /
|/| | |
|
* | | | Merge pull request #111 from rdiomar/multitopic_producers | Dana Powers | 2014-01-30 | 1 | -35/+44 |
|\ \ \ |
|
| * | | | Use TopicAndPartition when producing async messages | Omar Ghishan | 2014-01-27 | 1 | -8/+11 |
| * | | | Make producers take a topic argument at send rather than init time | Omar Ghishan | 2014-01-23 | 1 | -34/+40 |
| | |/
| |/| |
|
* | | | Resolve conflicts for #106 | Omar Ghishan | 2014-01-28 | 1 | -39/+70 |
|\ \ \
| |/ /
|/| | |
|
| * | | Add doc string for SimpleConsumer._get_message() | Omar Ghishan | 2014-01-20 | 1 | -0/+6 |
| * | | Make get_messages() update and commit offsets just before returning | Omar Ghishan | 2014-01-15 | 1 | -16/+35 |
| * | | Only use timeout if it's not None | Omar Ghishan | 2014-01-15 | 1 | -4/+5 |
| * | | Store fetched offsets separately. | Omar Ghishan | 2014-01-15 | 1 | -10/+14 |