From 90c729438a2e3f1b194e58231e41bd16bd7b7172 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Tue, 5 Apr 2016 22:54:28 -0700 Subject: Use version-indexed lists for request/response protocol structs --- kafka/protocol/offset.py | 13 ++++++++++--- 1 file changed, 10 insertions(+), 3 deletions(-) (limited to 'kafka/protocol/offset.py') diff --git a/kafka/protocol/offset.py b/kafka/protocol/offset.py index 606f1f1..57bf4ac 100644 --- a/kafka/protocol/offset.py +++ b/kafka/protocol/offset.py @@ -1,13 +1,16 @@ from .struct import Struct from .types import Array, Int16, Int32, Int64, Schema, String + class OffsetResetStrategy(object): LATEST = -1 EARLIEST = -2 NONE = 0 -class OffsetResponse(Struct): +class OffsetResponse_v0(Struct): + API_KEY = 2 + API_VERSION = 0 SCHEMA = Schema( ('topics', Array( ('topic', String('utf-8')), @@ -18,10 +21,10 @@ class OffsetResponse(Struct): ) -class OffsetRequest(Struct): +class OffsetRequest_v0(Struct): API_KEY = 2 API_VERSION = 0 - RESPONSE_TYPE = OffsetResponse + RESPONSE_TYPE = OffsetResponse_v0 SCHEMA = Schema( ('replica_id', Int32), ('topics', Array( @@ -34,3 +37,7 @@ class OffsetRequest(Struct): DEFAULTS = { 'replica_id': -1 } + + +OffsetRequest = [OffsetRequest_v0] +OffsetResponse = [OffsetResponse_v0] -- cgit v1.2.1