From f5a0e402dbd05eeaf96649e39d35524dd993d9ef Mon Sep 17 00:00:00 2001 From: Alex Eftimie Date: Mon, 19 Feb 2018 15:21:32 +0100 Subject: Fix response schema --- kafka/protocol/admin.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/kafka/protocol/admin.py b/kafka/protocol/admin.py index 775bcf0..40963ac 100644 --- a/kafka/protocol/admin.py +++ b/kafka/protocol/admin.py @@ -338,7 +338,8 @@ class CreatePartitionsResponse_v0(Response): API_KEY = 37 API_VERSION = 0 SCHEMA = Schema( - ('topic_error_codes', Array( + ('throttle_time_ms', Int32), + ('topic_errors', Array( ('topic', String('utf-8')), ('error_code', Int16), ('error_message', String('utf-8')))) -- cgit v1.2.1