From 79cec434acd184b1926306a40fd57ab7bc9e8200 Mon Sep 17 00:00:00 2001 From: Emmett Butler Date: Tue, 24 Jul 2018 19:15:45 +0000 Subject: [PATCH] disable new listoffsetrequest for now, since it requires new message format --- pykafka/protocol.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/pykafka/protocol.py b/pykafka/protocol.py index cc5a608f2..5901590b8 100644 --- a/pykafka/protocol.py +++ b/pykafka/protocol.py @@ -1182,7 +1182,8 @@ class ListOffsetRequest(Request): @classmethod def get_versions(cls): - return {0: ListOffsetRequest, 1: ListOffsetRequestV1} + # XXX use ListOffsetRequestV1 after 0.10 message format is supported + return {0: ListOffsetRequest, 1: ListOffsetRequest} def __init__(self, partition_requests): """Create a new offset request""" @@ -1304,7 +1305,8 @@ class ListOffsetResponse(Response): @classmethod def get_versions(cls): - return {0: ListOffsetResponse, 1: ListOffsetResponseV1} + # XXX use ListOffsetResponseV1 after 0.10 message format is supported + return {0: ListOffsetResponse, 1: ListOffsetResponse} def __init__(self, buff): """Deserialize into a new Response