openstack/deb-python-kafka
Code Issues Proposed changes

Cleanup protocol change comments

Browse Source
This commit is contained in:
Dana Powers
2017-06-19 17:18:59 -07:00
parent 2533680134
commit cf8c034b89
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
kafka/protocol/fetch.py
View File

@@ -135,7 +135,7 @@ class FetchRequest_v3(Request):
class FetchRequest_v4(Request): class FetchRequest_v4(Request):
"""Adds isolation_level field""" # Adds isolation_level field
API_KEY = 1 API_KEY = 1
API_VERSION = 4 API_VERSION = 4
RESPONSE_TYPE = FetchResponse_v4 RESPONSE_TYPE = FetchResponse_v4
@@ -155,7 +155,7 @@ class FetchRequest_v4(Request):
class FetchRequest_v5(Request): class FetchRequest_v5(Request):
"""This may only be used in broker-broker api calls""" # This may only be used in broker-broker api calls
API_KEY = 1 API_KEY = 1
API_VERSION = 5 API_VERSION = 5
RESPONSE_TYPE = FetchResponse_v5 RESPONSE_TYPE = FetchResponse_v5

2
kafka/protocol/metadata.py
View File

@@ -81,7 +81,7 @@ class MetadataResponse_v3(Response):
('host', String('utf-8')), ('host', String('utf-8')),
('port', Int32), ('port', Int32),
('rack', String('utf-8')))), ('rack', String('utf-8')))),
('cluster_id', String('utf-8')), # <-- Added cluster_id field in v2 ('cluster_id', String('utf-8')),
('controller_id', Int32), ('controller_id', Int32),
('topics', Array( ('topics', Array(
('error_code', Int16), ('error_code', Int16),