diff options
| author | David Arthur <mumrah@gmail.com> | 2013-04-02 19:55:51 -0400 |
|---|---|---|
| committer | David Arthur <mumrah@gmail.com> | 2013-04-02 20:20:32 -0400 |
| commit | c275c023c5958c3b2b7d1aaf8642f2475d7780c8 (patch) | |
| tree | a935408a6651558c541ca14759f2c8bdc472f23c /test/integration.py | |
| parent | 2690a5da966176a9259dcb992e6a927aa9193c60 (diff) | |
| download | kafka-python-c275c023c5958c3b2b7d1aaf8642f2475d7780c8.tar.gz | |
Update kafka-src to latest trunk, enable 0.8.1 features
Diffstat (limited to 'test/integration.py')
| -rw-r--r-- | test/integration.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/test/integration.py b/test/integration.py index a1fcce7..609cfc6 100644 --- a/test/integration.py +++ b/test/integration.py @@ -6,6 +6,7 @@ import shlex import shutil import socket import subprocess +import sys import tempfile from threading import Thread, Event import time @@ -73,7 +74,8 @@ class KafkaFixture(Thread): args = shlex.split("java -cp %s org.apache.zookeeper.ZooKeeperMain create /%s kafka-python" % (cp, self.zk_chroot)) proc = subprocess.Popen(args) ret = proc.wait() - assert ret == 0 + if ret != 0: + sys.exit(1) # Start Kafka @@ -354,7 +356,6 @@ class TestKafkaClient(unittest.TestCase): # Offset Tests # #################### - @unittest.skip("No supported until 0.8.1") def test_commit_fetch_offsets(self): req = OffsetCommitRequest("test_commit_fetch_offsets", 0, 42, "metadata") (resp,) = self.client.send_offset_commit_request("group", [req]) |