summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
* Merge branch 'master' into add_testsMark Roberts2014-05-061-1/+15
|\
| * Merge pull request #139 from alexcb/masterDana Powers2014-05-061-1/+15
| |\
| | * added random_start param to SimpleProducer to enable/disable randomization of...Alex Couture-Beil2014-04-011-4/+11
| | * Changed randomization to simply randomize the initial starting partition of t...Alex Couture-Beil2014-04-011-3/+7
| | * Modified SimpleProducer to randomize the initial round robin orderingAlex Couture-Beil2014-03-111-1/+4
| * | Fix lack of timeout support in KafkaClient and KafkaConnectionmaciejkula2014-04-162-2/+2
* | | Attempt to fix travis build. Decrease complexity of service.py in favor of in...Mark Roberts2014-05-064-8/+12
* | | Make commit() check for errors instead of simply assert no errorMark Roberts2014-04-301-1/+1
* | | Make BrokerRequestError a base class, make subclasses for each broker errorMark Roberts2014-04-303-53/+113
* | | Various fixesMark Roberts2014-04-252-2/+9
* | | Fix last remaining test by making autocommit more intuitiveMark Roberts2014-04-241-1/+1
* | | Split out kafka version environments, default tox no longer runs any integrat...Mark Roberts2014-04-231-11/+11
* | | Fix bug in socket timeout per PR #161 by maciejkula, add testMark Roberts2014-04-191-1/+1
* | | Split up and speed up producer based integration testsMark Roberts2014-04-172-1/+2
* | | Refactor away _get_conn_for_broker. Fix bug in _get_connMark Roberts2014-04-091-13/+6
* | | Merge branch 'master' into add_testsMark Roberts2014-04-081-0/+4
|\ \ \ | |/ /
| * | Commit in seek if autocommitMark Roberts2014-03-271-1/+4
| * | Make seek(); commit(); work without commit discarding the seek changeMark Roberts2014-03-251-0/+1
* | | Reinstate test_integrate, make test_protocol more explicit, create testutilMark Roberts2014-04-081-1/+1
* | | Explicit testing of protocol errors. Make tests more explicit, and start wor...Mark Roberts2014-04-082-4/+7
|/ /
* | Merge pull request #134 from wizzat/conn_refactorv0.9.0Dana Powers2014-03-213-26/+35
|\ \
| * \ Merge branch 'master' into conn_refactorMark Roberts2014-03-182-5/+5
| |\ \
| * \ \ Merge branch 'master' into conn_refactorMark Roberts2014-02-263-9/+46
| |\ \ \
| * | | | Fix grammar in error stringMark Roberts2014-02-251-1/+1
| * | | | Minor refactor in conn.py, update version in __init__.py, add ErrorStringMark Roberts2014-02-253-26/+35
* | | | | Merge pull request #109 from mrtheb/developDana Powers2014-03-212-10/+29
|\ \ \ \ \ | |_|_|/ / |/| | | |
| * | | | Merge branch 'master' into developmrtheb2014-03-175-15/+144
| |\ \ \ \
| * | | | | Changes based on comments by @rdiomar, plus added LeaderUnavailableError for ...mrtheb2014-02-152-4/+11
| * | | | | check for broker None in send_broker_aware_request (added test for it)mrtheb2014-01-311-5/+14
| * | | | | Merge branch 'master' into developmrtheb2014-01-312-74/+114
| |\ \ \ \ \
| * | | | | | Handle cases for partition with leader=-1 (not defined)Marc Labbe2014-01-312-10/+12
| * | | | | | added mockmrtheb2014-01-181-3/+4
* | | | | | | Check against basestring instead of str in collect.hosts.Saulius Zemaitaitis2014-03-171-1/+1
| |_|/ / / / |/| | | | |
* | | | | | If a broker refuses the connection, try the nextstephenarmstrong2014-03-131-3/+3
| |_|_|_|/ |/| | | |
* | | | | nit: fixed misspellingZack Dever2014-03-031-1/+1
| |_|_|/ |/| | |
* | | | Merge pull request #122 from mrtheb/multihostsOmar2014-02-263-9/+46
|\ \ \ \ | |_|_|/ |/| | |
| * | | clean up after comments from @rdiomarmrtheb2014-02-151-3/+5
| * | | Support list (or comma-separated) of hosts (replaces host and port arguments)mrtheb2014-02-092-7/+11
| * | | Merge branch 'master' into multihostsmrtheb2014-01-317-341/+471
| |\ \ \ | | | |/ | | |/|
| * | | Allow KafkaClient to take in a list of brokers for bootstrappingMarc Labbe2013-11-143-22/+48
* | | | Fix version in __init__.py to match setup.pyDavid Arthur2014-02-251-1/+1
* | | | Make it possible to read and write xerial snappyGreg Bowyer2014-02-191-3/+95
| |/ / |/| |
* | | Merge pull request #111 from rdiomar/multitopic_producersDana Powers2014-01-301-35/+44
|\ \ \
| * | | Use TopicAndPartition when producing async messagesOmar Ghishan2014-01-271-8/+11
| * | | Make producers take a topic argument at send rather than init timeOmar Ghishan2014-01-231-34/+40
| | |/ | |/|
* | | Resolve conflicts for #106Omar Ghishan2014-01-281-39/+70
|\ \ \ | |/ / |/| |
| * | Add doc string for SimpleConsumer._get_message()Omar Ghishan2014-01-201-0/+6
| * | Make get_messages() update and commit offsets just before returningOmar Ghishan2014-01-151-16/+35
| * | Only use timeout if it's not NoneOmar Ghishan2014-01-151-4/+5
| * | Store fetched offsets separately.Omar Ghishan2014-01-151-10/+14