Skip to content
This repository has been archived by the owner on Mar 24, 2021. It is now read-only.

Commit

Permalink
disable new listoffsetrequest for now, since it requires new message …
Browse files Browse the repository at this point in the history
…format
  • Loading branch information
emmettbutler committed Jul 24, 2018
1 parent 27899ce commit 79cec43
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions pykafka/protocol.py
Original file line number Diff line number Diff line change
Expand Up @@ -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"""
Expand Down Expand Up @@ -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
Expand Down

0 comments on commit 79cec43

Please sign in to comment.