summaryrefslogtreecommitdiff
path: root/kafka/protocol/fetch.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2015-11-29 10:00:50 +0800
committerZack Dever <zack.dever@rd.io>2015-12-04 11:25:40 -0800
commit058567912e8d82c1da5e5ead9e30be532573a173 (patch)
treeeb5cdd9d7c25729441cfa097772ca0623e4cbfe0 /kafka/protocol/fetch.py
parenta85e09df89a43de5b659a0fa4ed35bec37c60e04 (diff)
downloadkafka-python-058567912e8d82c1da5e5ead9e30be532573a173.tar.gz
Add simple BrokerConnection class; add request.RESPONSE_TYPE class vars
Diffstat (limited to 'kafka/protocol/fetch.py')
-rw-r--r--kafka/protocol/fetch.py24
1 files changed, 13 insertions, 11 deletions
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)))))
- )