From a3b7dca1b03e8d8d1e1e6c9339a5e12ccb5f51ea Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Mon, 2 May 2016 20:59:05 -0700 Subject: Add protocol support for ApiVersionRequest; identify 0.10 brokers in check_version --- kafka/protocol/admin.py | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) (limited to 'kafka/protocol/admin.py') diff --git a/kafka/protocol/admin.py b/kafka/protocol/admin.py index 8c74613..706bc3a 100644 --- a/kafka/protocol/admin.py +++ b/kafka/protocol/admin.py @@ -2,6 +2,28 @@ from .struct import Struct from .types import Array, Bytes, Int16, Schema, String +class ApiVersionResponse_v0(Struct): + API_KEY = 18 + API_VERSION = 0 + SCHEMA = Schema( + ('error_code', Int16), + ('api_versions', Array( + ('api_key', Int16), + ('min_version', Int16), + ('max_version', Int16)))) + + +class ApiVersionRequest_v0(Struct): + API_KEY = 18 + API_VERSION = 0 + RESPONSE_TYPE = ApiVersionResponse_v0 + SCHEMA = Schema() + + +ApiVersionRequest = [ApiVersionRequest_v0] +ApiVersionResponse = [ApiVersionResponse_v0] + + class ListGroupsResponse_v0(Struct): API_KEY = 16 API_VERSION = 0 -- cgit v1.2.1