From 6163aa3c633249c0ca7903d1b6d1ab209a927980 Mon Sep 17 00:00:00 2001 From: Stephen SORRIAUX Date: Thu, 5 Apr 2018 22:44:54 +0200 Subject: Fix CreatePartitionsRequest_v0 (#1469) --- 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 40963ac..de6b996 100644 --- a/kafka/protocol/admin.py +++ b/kafka/protocol/admin.py @@ -355,7 +355,7 @@ class CreatePartitionsRequest_v0(Request): ('topic', String('utf-8')), ('new_partitions', Schema( ('count', Int32), - ('assignment', Array(Int32)))))), + ('assignment', Array(Array(Int32))))))), ('timeout', Int32), ('validate_only', Boolean) ) -- cgit v1.2.1