diff options
| author | Stephen SORRIAUX <stephen.sorriaux@gmail.com> | 2018-04-05 22:44:54 +0200 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2018-04-05 13:44:54 -0700 |
| commit | 6163aa3c633249c0ca7903d1b6d1ab209a927980 (patch) | |
| tree | 0a7af6ca9e1e648ad73e7c73eed3c6e4f88981d3 | |
| parent | 4267ed582e6be6d599ddd54ce3e5a5921651fcad (diff) | |
| download | kafka-python-6163aa3c633249c0ca7903d1b6d1ab209a927980.tar.gz | |
Fix CreatePartitionsRequest_v0 (#1469)
| -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) ) |