summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Merge pull request #184 from itsyarkee/masterMark Roberts2014-08-021-1/+2
|\ | | | | Update setup.py
| * Update setup.pyYarkee Chou2014-07-191-1/+2
|/
* Merge pull request #166 from patricklucas/teach_producers_about_compressionDana Powers2014-05-194-31/+119
|\ | | | | Add 'codec' parameter to Producer
| * Improve error handling and tests w.r.t. codecsPatrick Lucas2014-05-074-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_compressionMark Roberts2014-05-073-25/+49
| |\ | | | | | | | | | | | | | | | Conflicts: servers/0.8.0/kafka-src test/test_unit.py
| | * Add 'codec' parameter to ProducerPatrick Lucas2014-05-033-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-1Dana Powers2014-05-121-3/+1
|\ \ \ | | | | | | | | Support IPv6 hosts and networks
| * | | Support IPv6 hosts and networksAlexey Borzenkov2014-05-091-3/+1
|/ / /
* | | Merge pull request #163 from patricklucas/remove_distribute_dependencyDana Powers2014-05-081-1/+0
|\ \ \ | |/ / |/| | Remove 'distribute' dependency
| * | Remove 'distribute' dependencyPatrick Lucas2014-05-021-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_testsDana Powers2014-05-0737-2001/+2729
|\ \ | | | | | | Improve Tests, fix connection error timeout, other issues
| * | Make test suite more robust against very slow test suitesMark Roberts2014-05-061-2/+2
| | |
| * | Merge branch 'master' into add_testsMark Roberts2014-05-062-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/masterDana Powers2014-05-062-24/+73
|\ \ \ | | | | | | | | SimpleProducer randomization of initial round robin ordering
| * | | added random_start param to SimpleProducer to enable/disable randomization ↵Alex Couture-Beil2014-04-011-4/+11
| | | | | | | | | | | | | | | | of the initial partition messages are published to
| * | | Changed randomization to simply randomize the initial starting partition of ↵Alex Couture-Beil2014-04-011-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 thatAlex Couture-Beil2014-03-121-23/+58
| | | | | | | | | | | | | | | | the initial round-robin ordering of partitions have been randomized
| * | | Modified SimpleProducer to randomize the initial round robin orderingAlex Couture-Beil2014-03-111-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_respectedDana Powers2014-05-052-2/+2
|\ \ \ \ | |_|_|/ |/| | | Fix connection timeout in KafkaClient and KafkaConnection
| * | | 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 ↵Mark Roberts2014-05-067-66/+38
| | | | | | | | | | | | | | | | in memory logging. Address code review concerns
| | | * Add pypy back to tox.iniMark Roberts2014-05-011-1/+1
| | | |
| | | * Attempt to reenable py26 and pypy buildsMark Roberts2014-05-012-7/+21
| | | |
| | | * Temporarily remove Python26 support from travis.ymlMark Roberts2014-04-301-9/+8
| | | |
| | | * Add missing importMark Roberts2014-04-301-0/+1
| | | |
| | | * Skip flaky test between osx/linuxMark Roberts2014-04-301-1/+1
| | | |
| | | * Temporarily remove pypy supportMark Roberts2014-04-302-10/+7
| | | |
| | | * Update travis.yml based on ↵Mark Roberts2014-04-301-7/+9
| | | | | | | | | | | | | | | | http://alexgaynor.net/2014/jan/06/why-travis-ci-is-great-for-the-python-community/
| | | * Remove libsnappy-javaMark Roberts2014-04-301-1/+0
| | | |
| | | * Attempt to install libsnappy in the travis environmentMark Roberts2014-04-301-0/+2
| | | |
| | | * Update travis.ymlMark Roberts2014-04-301-0/+1
| | | |
| | | * Merge branch 'exception_refactor' into add_testsMark Roberts2014-04-303-54/+114
| | | |\
| | | | * Make commit() check for errors instead of simply assert no errorMark Roberts2014-04-301-1/+1
| | | | |
| | | | * Merge branch 'add_tests' into exception_refactorMark Roberts2014-04-302-2/+2
| | | | |\
| | | | * | Make BrokerRequestError a base class, make subclasses for each broker errorMark Roberts2014-04-303-53/+113
| | | | | |
| | | * | | Update .travis.yml to support new test suiteMark Roberts2014-04-301-5/+6
| | | | |/ | | | |/|
| | | * | Build kafka 0.8.1 for only one version of scalaMiguel Eduardo Gil Biraud2014-04-301-1/+1
| | | | |
| | | * | Fix log directory as per documentation: ↵Miguel Eduardo Gil Biraud2014-04-301-1/+1
| | | |/ | | | | | | | | | | | | http://kafka.apache.org/08/documentation.html#brokerconfigs
| | | * Various fixesMark Roberts2014-04-258-22/+146
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Bump version number to 0.9.1 Update readme to show supported Kafka/Python versions Validate arguments in consumer.py, add initial consumer unit test Make service kill() child processes when startup fails Add tests for util.py, fix Python 2.6 specific bug.
| | | * Fix last remaining test by making autocommit more intuitiveMark Roberts2014-04-242-3/+3
| | | |
| | | * Fix Python 2.6 supportMark Roberts2014-04-2312-54/+39
| | | |
| | | * Update consumer_integration to flip the autocommit switch when testing kafka ↵Mark Roberts2014-04-231-30/+36
| | | | | | | | | | | | | | | | 0.8.1
| | | * Split out kafka version environments, default tox no longer runs any ↵Mark Roberts2014-04-238-36/+96
| | | | | | | | | | | | | | | | integration tests, make skipped integration also skip setupClass, implement rudimentary offset support in consumer.py
| | | * Add test support for multiple versions of kafka. Uncomment first 0.8.1 ↵Mark Roberts2014-04-237-12/+51
| | | | | | | | | | | | | | | | specific test. Add rudimentary (failing) consumer resumption test
| | | * Update READMEMark Roberts2014-04-231-23/+25
| | | |
| | | * Add support for kafka 0.8.1Mark Roberts2014-04-238-4/+115
| | | |
| | | * Move kafka-src to servers/0.8.0/kafka-src, move test/resources to ↵Mark Roberts2014-04-238-9/+11
| | | | | | | | | | | | | | | | servers/0.8.0/resources, update fixtures, add build_integration.sh for getting started with development
| | | * Update fixtures to eliminate extraneous logging on non-errors, split out ↵Mark Roberts2014-04-225-221/+240
| | | | | | | | | | | | | | | | mostly unrelated service.py, fix test in client_integration to use get_open_port, fix unintended import cascade in test_producer_integration
| | | * Merge branch 'master' into add_testsMark Roberts2014-04-211-0/+11
| | | |\ | |_|_|/ |/| | |
* | | | In memory of @rdiomar, 2014David Arthur2014-04-211-1/+1
| | | |
View Lorry Controller Status