92d4de169b
Again
David Arthur
2014-08-22 08:27:04 -04:00
9ff230412e
One. More. Time.
David Arthur
2014-08-22 00:04:16 -04:00
bca8ad9b72
Once more, with feeling
David Arthur
2014-08-21 23:39:50 -04:00
3b6a18ba45
Trying the real PyPI site
David Arthur
2014-08-21 22:56:22 -04:00
8d8e9cf73e
I can't win today
David Arthur
2014-08-21 22:25:41 -04:00
dd6fd1e79e
Trying yet again
David Arthur
2014-08-21 22:02:56 -04:00
69b55c9806
Change TravisCI badge to reflect master branch
David Arthur
2014-08-21 17:02:07 -04:00
bd5988fd99
Sometimes the correct password helps
David Arthur
2014-08-21 15:28:36 -04:00
416cc8f312
Trying TravisCI password again...
David Arthur
2014-08-21 14:22:37 -04:00
f51cc0e276
bumping version number for Travis/PyPI test
David Arthur
2014-08-21 13:50:24 -04:00
83f14816f3
Trying that again
David Arthur
2014-08-21 13:01:43 -04:00
25fd3390ac
Tell Travis to build release-* branches as well as master
David Arthur
2014-08-21 12:39:49 -04:00
313796c376
Update metadata in setup.py and add TravisCI PyPI deployment
David Arthur
2014-08-21 12:04:06 -04:00
1eed47c91c
Adding IRC to README
David Arthur
2014-08-21 08:17:33 -04:00
f862774e1a
Add a mock to sock.recv() in the test_conn setUp method. Returns 2 packet payloads, then '', then error
Dana Powers
2014-08-19 23:48:35 -07:00
767acb1b3c
Improve docstrings in kafka.conn
Dana Powers
2014-08-19 22:33:43 -07:00
cb3184554b
Shutdown socket before closing in kafka.conn
Dana Powers
2014-08-19 22:33:07 -07:00
7b9322f0e1
Remove duplicate error handling blocks by moving empty response check into try block in conn.recv
Dana Powers
2014-08-19 22:32:33 -07:00
472f287778
Remove self._dirty and check self._sock instead in kafka.conn
Dana Powers
2014-08-19 22:29:42 -07:00
24936881b7
Remove unused imports from test/test_conn.py
Dana Powers
2014-08-19 21:25:42 -07:00
f5802d8a7a
Implement last of the skipped test_conn.py tests
Dana Powers
2014-08-17 23:39:38 -07:00
635b293f0c
Implement a few more skipped tests in test/test_conn.py
Dana Powers
2014-08-17 23:11:33 -07:00
b106f3679e
Move common connection testing code to setUp method
Dana Powers
2014-08-17 23:10:51 -07:00
af899abe7c
Implementing more skipped connection tests (send and recv)
Dana Powers
2014-08-17 22:29:49 -07:00
839b8831bf
Cleanup some connection tests in test/test_conn.py
Dana Powers
2014-08-17 22:28:51 -07:00
0a762a0bac
socket.sendall should always raise an exception on error; remove extra return val check in KafkaConnection.send()
Dana Powers
2014-08-17 22:27:49 -07:00
dac157a6fb
Improve KafkaConnection testing: mock socket.create_connection; add tests for __init__ and send
Dana Powers
2014-08-17 20:05:13 -07:00
19499c3de6
Add some more debug logging to KafkaConnection
Dana Powers
2014-08-17 20:03:24 -07:00
45946d872f
Initialized _dirty in KafkaConnection __init__() and set _sock to None in close()
Dana Powers
2014-08-17 20:02:47 -07:00
fd3927c0d4
Call _raise_connection_error in KafkaConnection.reinit() if socket connection fails
Dana Powers
2014-08-17 16:05:03 -07:00
cea8ec3297
Add apt-get install libsnappy-dev instructions to README
Dana Powers
2014-08-13 08:10:55 -07:00
18fdddf37f
Add KafkaTimeoutError (used by client.ensure_topic_exists) and add a test
Dana Powers
2014-08-13 11:51:48 -07:00
5a02d6393d
Merge pull request #193 from dpkp/test_apache_binary_release
Mark Roberts
2014-08-14 02:16:54 -07:00
813a0bdaa2
Support integration testing against kafka source builds (see README)
vagrant
2014-08-13 22:01:29 -07:00
a6200f2e99
Increase fixture wait timeout to 30s; add wait-time logging
Dana Powers
2014-08-13 09:47:03 -07:00
4796d58792
Update tox.ini to use {posargs} to configure nosetests. 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
Dana Powers
2014-08-13 07:57:04 -07:00
e35835719e
Add kafka 0.8.1.1 to integration tests. - 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.
Dana Powers
2014-08-12 21:58:22 -07:00
d629b57a80
Remove kafka src submodules
Dana Powers
2014-08-12 21:51:44 -07:00
31e3c22656
Use travis env vars to run kafka version tests in parallel
Dana Powers
2014-08-12 21:19:48 -07:00
141e2db112
Use kafka_run_class_env() to set environment vars in test fixtures
Dana Powers
2014-08-12 20:15:46 -07:00
cfac060c5c
Add resource templates for kafka 0.8.1.1 test fixtures
Dana Powers
2014-08-12 17:27:45 -07:00
7238e5a73e
Download official binaries from apache.org for integration tests
Dana Powers
2014-08-12 17:26:58 -07:00
1908ee83d5
Add Fixtures.download_official_distribution to get binaries from apache.org
Dana Powers
2014-08-12 16:24:25 -07:00
c37dc89c6c
Merge pull request #174 from wizzat/new_topic
Dana Powers
2014-08-10 18:47:06 -07:00
3410fc742a
Bump version to 0.9.1
v0.9.1
Dana Powers
2014-08-10 18:39:24 -07:00
e81b13a832
Set module version in separate VERSION file
Dana Powers
2014-08-10 18:18:02 -07:00
7bfdafa9e7
Merge pull request #184 from itsyarkee/master
Mark Roberts
2014-08-02 19:09:15 -07:00
31532ba967
Fix Py26 test cases
Mark Roberts
2014-05-22 13:35:08 -07:00
35a14e18c6
Handle New Topic Creation
Mark Roberts
2014-05-22 12:06:38 -07:00
ae6b49aca1
Merge pull request #166 from patricklucas/teach_producers_about_compression
Dana Powers
2014-05-19 19:44:23 -07:00
b13fa3f4a2
Merge pull request #169 from snaury/patch-1
Dana Powers
2014-05-12 09:26:50 -07:00
2e9a247b33
Support IPv6 hosts and networks
Alexey Borzenkov
2014-05-09 13:37:29 +04:00
fddc152590
Merge pull request #163 from patricklucas/remove_distribute_dependency
Dana Powers
2014-05-08 19:55:57 -07:00
805b52a34d
Improve error handling and tests w.r.t. codecs
Patrick Lucas
2014-05-07 10:02:57 -07:00
39796ec491
Merge branch 'teach_producers_about_compression' into producer_compression
Mark Roberts
2014-05-07 03:05:50 -07:00
b47bf781eb
Merge pull request #158 from wizzat/add_tests
Dana Powers
2014-05-07 00:04:04 -07:00
b81bf5f69e
Make test suite more robust against very slow test suites
Mark Roberts
2014-05-06 22:56:24 -07:00
b053da2203
Merge branch 'master' into add_tests
Mark Roberts
2014-05-06 21:54:02 -07:00
efcf58b842
Attempt to fix travis build. Decrease complexity of service.py in favor of in memory logging. Address code review concerns
Mark Roberts
2014-05-06 21:24:15 -07:00
3b18043821
Merge pull request #139 from alexcb/master
Dana Powers
2014-05-06 21:03:10 -07:00
914c2e686a
Merge pull request #161 from maciejkula/bug/timeout_not_respected
Dana Powers
2014-05-05 21:07:15 -07:00
671b74ab2e
Add 'codec' parameter to Producer
Patrick Lucas
2014-05-03 11:27:57 -07:00
a729e8cbc8
Remove 'distribute' dependency
Patrick Lucas
2014-05-02 19:14:48 -07:00
99320fbd8c
Add pypy back to tox.ini
Mark Roberts
2014-05-01 10:29:38 -07:00
b120ca5d72
Attempt to reenable py26 and pypy builds
Mark Roberts
2014-05-01 10:27:30 -07:00
83d95710e5
Temporarily remove Python26 support from travis.yml
Mark Roberts
2014-04-30 22:02:05 -07:00
c307a3aac6
Add missing import
Mark Roberts
2014-04-30 21:33:03 -07:00
7a1e2270cb
Skip flaky test between osx/linux
Mark Roberts
2014-04-30 21:19:37 -07:00
26ae50254b
Temporarily remove pypy support
Mark Roberts
2014-04-30 20:34:14 -07:00
0d57c2718f
Make BrokerRequestError a base class, make subclasses for each broker error
Mark Roberts
2014-04-30 17:39:39 -07:00
57913f9f91
Various fixes
Mark Roberts
2014-04-25 10:55:04 -07:00
0e50f33ec6
Fix last remaining test by making autocommit more intuitive
Mark Roberts
2014-04-24 00:25:35 -07:00
583d3ae22b
Fix Python 2.6 support
Mark Roberts
2014-04-23 13:10:43 -07:00
764f2053ad
Update consumer_integration to flip the autocommit switch when testing kafka 0.8.1
Mark Roberts
2014-04-23 12:15:30 -07:00
8a1f2e6c3a
Split out kafka version environments, default tox no longer runs any integration tests, make skipped integration also skip setupClass, implement rudimentary offset support in consumer.py
Mark Roberts
2014-04-23 11:26:27 -07:00
86e1ac7b96
Add test support for multiple versions of kafka. Uncomment first 0.8.1 specific test. Add rudimentary (failing) consumer resumption test
Mark Roberts
2014-04-23 09:29:30 -07:00
7c21dfece7
Update README
Mark Roberts
2014-04-23 02:21:50 -07:00
7e5c847aa9
Add support for kafka 0.8.1
Mark Roberts
2014-04-23 02:04:04 -07:00
6628c109b7
Move kafka-src to servers/0.8.0/kafka-src, move test/resources to servers/0.8.0/resources, update fixtures, add build_integration.sh for getting started with development
Mark Roberts
2014-04-23 00:04:09 -07:00
b6262e4c0b
Update fixtures to eliminate extraneous logging on non-errors, split out mostly unrelated service.py, fix test in client_integration to use get_open_port, fix unintended import cascade in test_producer_integration
Mark Roberts
2014-04-22 23:14:23 -07:00
d35b8fd81f
Merge branch 'master' into add_tests
Mark Roberts
2014-04-21 22:01:32 -07:00
2415609ce0
In memory of @rdiomar, 2014
David Arthur
2014-04-21 11:20:44 -04:00
46c74c1b64
Update AUTHORS.md
David Arthur
2014-04-21 11:14:21 -04:00
a7cbfd361d
Fix bug in socket timeout per PR #161 by maciejkula, add test
Mark Roberts
2014-04-19 11:00:44 -07:00
1984dab59f
Finish breaking out integration tests
Mark Roberts
2014-04-17 17:43:38 -07:00
8983e73437
Split up and speed up producer based integration tests
Mark Roberts
2014-04-17 16:11:57 -07:00
7eaca8eea7
Split out and speed up producer tests
Mark Roberts
2014-04-17 10:29:13 -07:00
ef4648a084
Fix lack of timeout support in KafkaClient and KafkaConnection
maciejkula
2014-04-16 17:05:45 +01:00