diff options
| -rw-r--r-- | kafka/protocol/admin.py | 2 |
1 files changed, 1 insertions, 1 deletions
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) ) |