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/metadata.py | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) (limited to 'kafka/protocol/metadata.py') diff --git a/kafka/protocol/metadata.py b/kafka/protocol/metadata.py index 810f1b8..8063dda 100644 --- a/kafka/protocol/metadata.py +++ b/kafka/protocol/metadata.py @@ -2,7 +2,9 @@ from .struct import Struct from .types import Array, Int16, Int32, Schema, String -class MetadataResponse(Struct): +class MetadataResponse_v0(Struct): + API_KEY = 3 + API_VERSION = 0 SCHEMA = Schema( ('brokers', Array( ('node_id', Int32), @@ -20,10 +22,14 @@ class MetadataResponse(Struct): ) -class MetadataRequest(Struct): +class MetadataRequest_v0(Struct): API_KEY = 3 API_VERSION = 0 - RESPONSE_TYPE = MetadataResponse + RESPONSE_TYPE = MetadataResponse_v0 SCHEMA = Schema( ('topics', Array(String('utf-8'))) ) + + +MetadataRequest = [MetadataRequest_v0] +MetadataResponse = [MetadataResponse_v0] -- cgit v1.2.1