From 3260671cef403d88388f73fb2b94efd84958a30e Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Fri, 23 Nov 2018 10:17:59 -0800 Subject: Fix response error checking in KafkaAdminClient send_to_controller --- kafka/protocol/admin.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'kafka/protocol/admin.py') diff --git a/kafka/protocol/admin.py b/kafka/protocol/admin.py index fc62c35..9f67af8 100644 --- a/kafka/protocol/admin.py +++ b/kafka/protocol/admin.py @@ -619,7 +619,7 @@ class CreatePartitionsResponse_v0(Response): API_VERSION = 0 SCHEMA = Schema( ('throttle_time_ms', Int32), - ('topic_errors', Array( + ('topic_error_codes', Array( ('topic', String('utf-8')), ('error_code', Int16), ('error_message', String('utf-8')))) -- cgit v1.2.1