From e14d72c21b94a6753d218893d3c6ad225c5c72fa Mon Sep 17 00:00:00 2001 From: Stephen Date: Wed, 4 Apr 2018 23:50:54 +0200 Subject: [PATCH] Fix CreatePartitionsRequest_v0 --- kafka/protocol/admin.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/protocol/admin.py b/kafka/protocol/admin.py index 40963acb1..de6b996fd 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) )