Fix CreatePartitionsRequest_v0 (#1469)

StephenSorriaux · dpkp · commit 6163aa3c6332 · 2018-04-05T13:44:54.000-07:00
diff --git 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)
     )

Original file line number	Diff line number	Diff line change
`@@ -355,7 +355,7 @@ class CreatePartitionsRequest_v0(Request):`
`355`	`355`	`('topic', String('utf-8')),`
`356`	`356`	`('new_partitions', Schema(`
`357`	`357`	`('count', Int32),`
`358`		`- ('assignment', Array(Int32)))))),`
	`358`	`+ ('assignment', Array(Array(Int32))))))),`
`359`	`359`	`('timeout', Int32),`
`360`	`360`	`('validate_only', Boolean)`
`361`	`361`	`)`