openstack/deb-python-kafka
Code Issues Proposed changes

Add FetchRequest/Response_v3 structs (#943)

Browse Source
This commit is contained in:
Jeff Widman
2017-01-18 16:52:29 -08:00
committed by Dana Powers
parent 2c6261a4d6
commit 7df120d7ce
1 changed files with 28 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
kafka/protocol/fetch.py
View File

@@ -40,6 +40,12 @@ class FetchResponse_v2(Struct):
SCHEMA = FetchResponse_v1.SCHEMA # message format changed internally SCHEMA = FetchResponse_v1.SCHEMA # message format changed internally
class FetchResponse_v3(Struct):
API_KEY = 1
API_VERSION = 3
SCHEMA = FetchResponse_v2.SCHEMA
class FetchRequest_v0(Struct): class FetchRequest_v0(Struct):
API_KEY = 1 API_KEY = 1
API_VERSION = 0 API_VERSION = 0
@@ -71,5 +77,25 @@ class FetchRequest_v2(Struct):
SCHEMA = FetchRequest_v1.SCHEMA SCHEMA = FetchRequest_v1.SCHEMA
FetchRequest = [FetchRequest_v0, FetchRequest_v1, FetchRequest_v2] class FetchRequest_v3(Struct):
FetchResponse = [FetchResponse_v0, FetchResponse_v1, FetchResponse_v2] API_KEY = 1
API_VERSION = 3
RESPONSE_TYPE = FetchResponse_v3
SCHEMA = Schema(
('replica_id', Int32),
('max_wait_time', Int32),
('min_bytes', Int32),
('max_bytes', Int32), # This new field is only difference from FR_v2
('topics', Array(
('topic', String('utf-8')),
('partitions', Array(
('partition', Int32),
('offset', Int64),
('max_bytes', Int32)))))
)
FetchRequest = [FetchRequest_v0, FetchRequest_v1, FetchRequest_v2,
FetchRequest_v3]
FetchResponse = [FetchResponse_v0, FetchResponse_v1, FetchResponse_v2,
FetchResponse_v3]