1 files changed, 9 insertions, 8 deletions
diff --git a/kafka/protocol/metadata.py b/kafka/protocol/metadata.py
index b35e7ef..810f1b8 100644
--- a/kafka/protocol/metadata.py
+++ b/kafka/protocol/metadata.py
@@ -2,14 +2,6 @@ from .struct import Struct
 from .types import Array, Int16, Int32, Schema, String
 
 
-class MetadataRequest(Struct):
-    API_KEY = 3
-    API_VERSION = 0
-    SCHEMA = Schema(
-        ('topics', Array(String('utf-8')))
-    )
-
-
 class MetadataResponse(Struct):
     SCHEMA = Schema(
         ('brokers', Array(
@@ -26,3 +18,12 @@ class MetadataResponse(Struct):
                 ('replicas', Array(Int32)),
                 ('isr', Array(Int32))))))
     )
+
+
+class MetadataRequest(Struct):
+    API_KEY = 3
+    API_VERSION = 0
+    RESPONSE_TYPE = MetadataResponse
+    SCHEMA = Schema(
+        ('topics', Array(String('utf-8')))
+    )