| Commit message (Collapse) | Author | Age | Files | Lines |
... | |
|\ \ \ \
| | | | |
| | | | | |
Add KafkaTimeoutError and fix client.ensure_topic_exists
|
| | | | | |
|
| |/ / /
|/| | |
| | | |
| | | | |
Tags applied to master will now be automatically deployed on PyPI
|
| | | | |
|
| | | | |
|
| |/ /
|/| | |
|
|/ / |
|
|\ \
| | |
| | | |
Use Kafka Binaries for Integration Tests (Issue #176)
|
| | | |
|
| | | |
|
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
To override defaults, use
`tox -- --your --nosetest --options --here`
Update default nosetest settings to use verbose logging and show test ids
add .coverage and .noseids to .gitignore
Add example for running single unit test to README
|
| | |
| | |
| | |
| | |
| | |
| | | |
- 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.
|
| | | |
|
| | | |
|
| | | |
|
| | | |
|
| | | |
|
|/ / |
|
|\ \
| | |
| | | |
Handle New Topic Creation
|
| | | |
|
| | |
| | |
| | |
| | |
| | | |
Adds ensure_topic_exists to KafkaClient, redirects test case to use
that. Fixes #113 and fixes #150.
|
| | | |
|
| | | |
|
|\ \ \
| |/ /
|/| | |
Update setup.py
|
|/ / |
|
|\ \
| | |
| | | |
Add 'codec' parameter to Producer
|
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
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.
|
| |\ \
| | | |
| | | |
| | | |
| | | |
| | | | |
Conflicts:
servers/0.8.0/kafka-src
test/test_unit.py
|
| | | |
| | | |
| | | |
| | | |
| | | | |
Adds a codec parameter to Producer.__init__ that lets the user choose
a compression codec to use for all messages sent by it.
|
|\ \ \ \
| | | | |
| | | | | |
Support IPv6 hosts and networks
|
|/ / / / |
|
|\ \ \ \
| |/ / /
|/| | | |
Remove 'distribute' dependency
|
| |/ /
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
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'
|
|\ \ \
| | | |
| | | | |
Improve Tests, fix connection error timeout, other issues
|
| | | | |
|
| |\ \ \
| |/ / /
|/| | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | | |
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
|
|\ \ \ \
| | | | |
| | | | | |
SimpleProducer randomization of initial round robin ordering
|
| | | | |
| | | | |
| | | | |
| | | | | |
of the initial partition messages are published to
|
| | | | |
| | | | |
| | | | |
| | | | | |
the sorted list of partition rather than completely randomizing the initial ordering before round-robin cycling the partitions
|
| | | | |
| | | | |
| | | | |
| | | | | |
the initial round-robin ordering of partitions have been randomized
|
| | | | |
| | | | |
| | | | |
| | | | |
| | | | | |
of partitions to prevent the first message from always being published
to partition 0.
|
|\ \ \ \ \
| |_|_|/ /
|/| | | | |
Fix connection timeout in KafkaClient and KafkaConnection
|
| | | | | |
|
| | | | |
| | | | |
| | | | |
| | | | | |
in memory logging. Address code review concerns
|
| | | | | |
|
| | | | | |
|
| | | | | |
|
| | | | | |
|
| | | | | |
|
| | | | | |
|