summaryrefslogtreecommitdiff
path: root/test/test_client_integration.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2015-12-10 10:57:27 -0800
committerDana Powers <dana.powers@rd.io>2015-12-10 11:25:15 -0800
commit7470cade6bb8629d17541e136527369f9d2ec387 (patch)
treeba424c4d0cc27ffb5ec77196a0e121f3075bc992 /test/test_client_integration.py
parentc3d2fda3c368771cb93a09bb2f1edaa7a3cf9c2b (diff)
downloadkafka-python-7470cade6bb8629d17541e136527369f9d2ec387.tar.gz
Convert OffsetCommit and OffsetFetch protocol encode/decode
Diffstat (limited to 'test/test_client_integration.py')
-rw-r--r--test/test_client_integration.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/test/test_client_integration.py b/test/test_client_integration.py
index 70da4a3..edd62da 100644
--- a/test/test_client_integration.py
+++ b/test/test_client_integration.py
@@ -1,7 +1,7 @@
import os
from kafka.common import (
- FetchRequestPayload, OffsetCommitRequest, OffsetFetchRequest,
+ FetchRequestPayload, OffsetCommitRequestPayload, OffsetFetchRequestPayload,
KafkaTimeoutError, ProduceRequestPayload
)
from kafka.protocol import create_message
@@ -85,11 +85,11 @@ class TestKafkaClientIntegration(KafkaIntegrationTestCase):
@kafka_versions("0.8.1", "0.8.1.1", "0.8.2.1")
def test_commit_fetch_offsets(self):
- req = OffsetCommitRequest(self.bytes_topic, 0, 42, b"metadata")
+ req = OffsetCommitRequestPayload(self.bytes_topic, 0, 42, b"metadata")
(resp,) = self.client.send_offset_commit_request(b"group", [req])
self.assertEqual(resp.error, 0)
- req = OffsetFetchRequest(self.bytes_topic, 0)
+ req = OffsetFetchRequestPayload(self.bytes_topic, 0)
(resp,) = self.client.send_offset_fetch_request(b"group", [req])
self.assertEqual(resp.error, 0)
self.assertEqual(resp.offset, 42)