From 058567912e8d82c1da5e5ead9e30be532573a173 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@rd.io>
Date: Sun, 29 Nov 2015 10:00:50 +0800
Subject: Add simple BrokerConnection class; add request.RESPONSE_TYPE class
 vars

---
 kafka/protocol/fetch.py | 24 +++++++++++++-----------
 1 file changed, 13 insertions(+), 11 deletions(-)

(limited to 'kafka/protocol/fetch.py')

diff --git a/kafka/protocol/fetch.py b/kafka/protocol/fetch.py
index c6d60cc..e00c9ab 100644
--- a/kafka/protocol/fetch.py
+++ b/kafka/protocol/fetch.py
@@ -3,9 +3,22 @@ from .struct import Struct
 from .types import Array, Int16, Int32, Int64, Schema, String
 
 
+class FetchResponse(Struct):
+    SCHEMA = Schema(
+        ('topics', Array(
+            ('topics', String('utf-8')),
+            ('partitions', Array(
+                ('partition', Int32),
+                ('error_code', Int16),
+                ('highwater_offset', Int64),
+                ('message_set', MessageSet)))))
+    )
+
+
 class FetchRequest(Struct):
     API_KEY = 1
     API_VERSION = 0
+    RESPONSE_TYPE = FetchResponse
     SCHEMA = Schema(
         ('replica_id', Int32),
         ('max_wait_time', Int32),
@@ -17,14 +30,3 @@ class FetchRequest(Struct):
                 ('offset', Int64),
                 ('max_bytes', Int32)))))
     )
-
-class FetchResponse(Struct):
-    SCHEMA = Schema(
-        ('topics', Array(
-            ('topics', String('utf-8')),
-            ('partitions', Array(
-                ('partition', Int32),
-                ('error_code', Int16),
-                ('highwater_offset', Int64),
-                ('message_set', MessageSet)))))
-    )
-- 
cgit v1.2.1