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) )