Commit message (Collapse) | Author | Age | Files | Lines | ||
---|---|---|---|---|---|---|
... | ||||||
| * | | Add kafka 0.8.1.1 to integration tests. | Dana Powers | 2014-08-13 | 6 | -18/+5 | |
| | | | | | | | | | | | | | | | | | | - previous 0.8.1 src appears to have actually been 0.8.1.1 based on git submodule commit. So technically this adds back 0.8.1 to the test suite. | |||||
| * | | Remove kafka src submodules | Dana Powers | 2014-08-13 | 4 | -21/+1 | |
| | | | ||||||
| * | | Use travis env vars to run kafka version tests in parallel | Dana Powers | 2014-08-12 | 2 | -10/+12 | |
| | | | ||||||
| * | | Use kafka_run_class_env() to set environment vars in test fixtures | Dana Powers | 2014-08-12 | 2 | -17/+17 | |
| | | | ||||||
| * | | Add resource templates for kafka 0.8.1.1 test fixtures | Dana Powers | 2014-08-12 | 3 | -0/+163 | |
| | | | ||||||
| * | | Download official binaries from apache.org for integration tests | Dana Powers | 2014-08-12 | 3 | -4/+32 | |
| | | | ||||||
| * | | Add Fixtures.download_official_distribution to get binaries from apache.org | Dana Powers | 2014-08-12 | 1 | -0/+39 | |
|/ / | ||||||
* | | Merge pull request #174 from wizzat/new_topic | Dana Powers | 2014-08-10 | 4 | -23/+34 | |
|\ \ | | | | | | | Handle New Topic Creation | |||||
| * | | Fix Py26 test cases | Mark Roberts | 2014-05-22 | 1 | -1/+1 | |
| | | | ||||||
| * | | Handle New Topic Creation | Mark Roberts | 2014-05-22 | 4 | -23/+34 | |
| | | | | | | | | | | | | | | | Adds ensure_topic_exists to KafkaClient, redirects test case to use that. Fixes #113 and fixes #150. | |||||
* | | | Bump version to 0.9.1v0.9.1 | Dana Powers | 2014-08-10 | 1 | -1/+1 | |
| | | | ||||||
* | | | Set module version in separate VERSION file | Dana Powers | 2014-08-10 | 4 | -2/+8 | |
| | | | ||||||
* | | | Merge pull request #184 from itsyarkee/master | Mark Roberts | 2014-08-02 | 1 | -1/+2 | |
|\ \ \ | |/ / |/| | | Update setup.py | |||||
| * | | Update setup.py | Yarkee Chou | 2014-07-19 | 1 | -1/+2 | |
|/ / | ||||||
* | | Merge pull request #166 from patricklucas/teach_producers_about_compression | Dana Powers | 2014-05-19 | 4 | -31/+119 | |
|\ \ | | | | | | | Add 'codec' parameter to Producer | |||||
| * | | Improve error handling and tests w.r.t. codecs | Patrick Lucas | 2014-05-07 | 4 | -27/+91 | |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Add function kafka.protocol.create_message_set() that takes a list of payloads and a codec and returns a message set with the desired encoding. Introduce kafka.common.UnsupportedCodecError, raised if an unknown codec is specified. Include a test for the new function. | |||||
| * | | Merge branch 'teach_producers_about_compression' into producer_compression | Mark Roberts | 2014-05-07 | 3 | -25/+49 | |
| |\ \ | | | | | | | | | | | | | | | | | | | | | Conflicts: servers/0.8.0/kafka-src test/test_unit.py | |||||
| | * | | Add 'codec' parameter to Producer | Patrick Lucas | 2014-05-03 | 3 | -24/+49 | |
| | | | | | | | | | | | | | | | | | | | | Adds a codec parameter to Producer.__init__ that lets the user choose a compression codec to use for all messages sent by it. | |||||
* | | | | Merge pull request #169 from snaury/patch-1 | Dana Powers | 2014-05-12 | 1 | -3/+1 | |
|\ \ \ \ | | | | | | | | | | | Support IPv6 hosts and networks | |||||
| * | | | | Support IPv6 hosts and networks | Alexey Borzenkov | 2014-05-09 | 1 | -3/+1 | |
|/ / / / | ||||||
* | | | | Merge pull request #163 from patricklucas/remove_distribute_dependency | Dana Powers | 2014-05-08 | 1 | -1/+0 | |
|\ \ \ \ | |/ / / |/| | | | Remove 'distribute' dependency | |||||
| * | | | Remove 'distribute' dependency | Patrick Lucas | 2014-05-02 | 1 | -1/+0 | |
| |/ / | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This dependency is unnecessary since this project now uses setuptools and it prevents installing this package with --use-wheel, failing with this traceback: $ pip install --use-wheel distribute Downloading/unpacking distribute Downloading distribute-0.7.3-cp26-none-linux_x86_64.whl Requirement already satisfied (use --upgrade to upgrade): setuptools>=0.7 in ./venv/lib/python2.6/site-packages (from distribute) Cleaning up... Exception: Traceback (most recent call last): File "/home/plucas/lib/python2.6/site-packages/pip/basecommand.py", line 134, in main status = self.run(options, args) File "/home/plucas/lib/python2.6/site-packages/pip/commands/install.py", line 241, in run requirement_set.install(install_options, global_options, root=options.root_path) File "/home/plucas/lib/python2.6/site-packages/pip/req.py", line 1256, in install if req.name == 'distribute' and req.installed_version in distribute_req: File "/home/plucas/lib/python2.6/site-packages/pip/req.py", line 390, in installed_version return self.pkg_info()['version'] File "/home/plucas/lib/python2.6/site-packages/pip/req.py", line 357, in pkg_info data = self.egg_info_data('PKG-INFO') File "/home/plucas/lib/python2.6/site-packages/pip/req.py", line 293, in egg_info_data filename = self.egg_info_path(filename) File "/home/plucas/lib/python2.6/site-packages/pip/req.py", line 307, in egg_info_path filenames = os.listdir(base) OSError: [Errno 2] No such file or directory: '/home/plucas/build/distribute/pip-egg-info' | |||||
* | | | Merge pull request #158 from wizzat/add_tests | Dana Powers | 2014-05-07 | 37 | -2001/+2729 | |
|\ \ \ | | | | | | | | | Improve Tests, fix connection error timeout, other issues | |||||
| * | | | Make test suite more robust against very slow test suites | Mark Roberts | 2014-05-06 | 1 | -2/+2 | |
| | | | | ||||||
| * | | | Merge branch 'master' into add_tests | Mark Roberts | 2014-05-06 | 2 | -7/+39 | |
| |\ \ \ | |/ / / |/| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | kafka/client.py contained duplicate copies of same refactor, merged. Move test/test_integration.py changes into test/test_producer_integration. Conflicts: kafka/client.py servers/0.8.0/kafka-src test/test_integration.py | |||||
* | | | | Merge pull request #139 from alexcb/master | Dana Powers | 2014-05-06 | 2 | -24/+73 | |
|\ \ \ \ | | | | | | | | | | | SimpleProducer randomization of initial round robin ordering | |||||
| * | | | | added random_start param to SimpleProducer to enable/disable randomization ↵ | Alex Couture-Beil | 2014-04-01 | 1 | -4/+11 | |
| | | | | | | | | | | | | | | | | | | | | of the initial partition messages are published to | |||||
| * | | | | Changed randomization to simply randomize the initial starting partition of ↵ | Alex Couture-Beil | 2014-04-01 | 1 | -3/+7 | |
| | | | | | | | | | | | | | | | | | | | | the sorted list of partition rather than completely randomizing the initial ordering before round-robin cycling the partitions | |||||
| * | | | | Modified SimpleProducer-based integration tests to work now that | Alex Couture-Beil | 2014-03-12 | 1 | -23/+58 | |
| | | | | | | | | | | | | | | | | | | | | the initial round-robin ordering of partitions have been randomized | |||||
| * | | | | Modified SimpleProducer to randomize the initial round robin ordering | Alex Couture-Beil | 2014-03-11 | 1 | -1/+4 | |
| | | | | | | | | | | | | | | | | | | | | | | | | | of partitions to prevent the first message from always being published to partition 0. | |||||
* | | | | | Merge pull request #161 from maciejkula/bug/timeout_not_respected | Dana Powers | 2014-05-05 | 2 | -2/+2 | |
|\ \ \ \ \ | |_|_|/ / |/| | | | | Fix connection timeout in KafkaClient and KafkaConnection | |||||
| * | | | | 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 ↵ | Mark Roberts | 2014-05-06 | 7 | -66/+38 | |
| | | | | | | | | | | | | | | | | | | | | in memory logging. Address code review concerns | |||||
| | | * | | Add pypy back to tox.ini | Mark Roberts | 2014-05-01 | 1 | -1/+1 | |
| | | | | | ||||||
| | | * | | Attempt to reenable py26 and pypy builds | Mark Roberts | 2014-05-01 | 2 | -7/+21 | |
| | | | | | ||||||
| | | * | | Temporarily remove Python26 support from travis.yml | Mark Roberts | 2014-04-30 | 1 | -9/+8 | |
| | | | | | ||||||
| | | * | | Add missing import | Mark Roberts | 2014-04-30 | 1 | -0/+1 | |
| | | | | | ||||||
| | | * | | Skip flaky test between osx/linux | Mark Roberts | 2014-04-30 | 1 | -1/+1 | |
| | | | | | ||||||
| | | * | | Temporarily remove pypy support | Mark Roberts | 2014-04-30 | 2 | -10/+7 | |
| | | | | | ||||||
| | | * | | Update travis.yml based on ↵ | Mark Roberts | 2014-04-30 | 1 | -7/+9 | |
| | | | | | | | | | | | | | | | | | | | | http://alexgaynor.net/2014/jan/06/why-travis-ci-is-great-for-the-python-community/ | |||||
| | | * | | Remove libsnappy-java | Mark Roberts | 2014-04-30 | 1 | -1/+0 | |
| | | | | | ||||||
| | | * | | Attempt to install libsnappy in the travis environment | Mark Roberts | 2014-04-30 | 1 | -0/+2 | |
| | | | | | ||||||
| | | * | | Update travis.yml | Mark Roberts | 2014-04-30 | 1 | -0/+1 | |
| | | | | | ||||||
| | | * | | Merge branch 'exception_refactor' into add_tests | Mark Roberts | 2014-04-30 | 3 | -54/+114 | |
| | | |\ \ | ||||||
| | | | * | | Make commit() check for errors instead of simply assert no error | Mark Roberts | 2014-04-30 | 1 | -1/+1 | |
| | | | | | | ||||||
| | | | * | | Merge branch 'add_tests' into exception_refactor | Mark Roberts | 2014-04-30 | 2 | -2/+2 | |
| | | | |\ \ | ||||||
| | | | * | | | Make BrokerRequestError a base class, make subclasses for each broker error | Mark Roberts | 2014-04-30 | 3 | -53/+113 | |
| | | | | | | | ||||||
| | | * | | | | Update .travis.yml to support new test suite | Mark Roberts | 2014-04-30 | 1 | -5/+6 | |
| | | | |/ / | | | |/| | | ||||||
| | | * | | | Build kafka 0.8.1 for only one version of scala | Miguel Eduardo Gil Biraud | 2014-04-30 | 1 | -1/+1 | |
| | | | | | | ||||||
| | | * | | | Fix log directory as per documentation: ↵ | Miguel Eduardo Gil Biraud | 2014-04-30 | 1 | -1/+1 | |
| | | |/ / | | | | | | | | | | | | | | | | http://kafka.apache.org/08/documentation.html#brokerconfigs |