delta/python-packages/kafka-python.git/test, branch release-0.9.x

Improve error handling and tests w.r.t. codecs

2014-05-07T17:08:14+00:00

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

2014-05-07T10:05:50+00:00

Conflicts:
	servers/0.8.0/kafka-src
	test/test_unit.py

Make test suite more robust against very slow test suites

2014-05-07T05:56:24+00:00

Merge branch 'master' into add_tests

2014-05-07T04:54:02+00:00

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

Attempt to fix travis build. Decrease complexity of service.py in favor of in memory logging. Address code review concerns

2014-05-07T04:24:15+00:00

Merge pull request #139 from alexcb/master

2014-05-07T04:03:10+00:00

SimpleProducer randomization of initial round robin ordering

Add 'codec' parameter to Producer

2014-05-03T23:09:33+00:00

Adds a codec parameter to Producer.__init__ that lets the user choose
a compression codec to use for all messages sent by it.

Add missing import

2014-05-01T04:33:03+00:00

Skip flaky test between osx/linux

2014-05-01T04:19:37+00:00

Various fixes

2014-04-25T17:55:04+00:00

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.