Fix CreatePartitionsRequest_v0 (dpkp#1469)

StephenSorriaux · 88manpreet · commit ea7187d0baf8 · 2018-07-31T18:20:36.000-07:00
diff --git a/kafka/protocol/admin.py b/kafka/protocol/admin.py
@@ -450,7 +450,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
`@@ -450,7 +450,7 @@ class CreatePartitionsRequest_v0(Request):`
`450`	`450`	`('topic', String('utf-8')),`
`451`	`451`	`('new_partitions', Schema(`
`452`	`452`	`('count', Int32),`
`453`		`- ('assignment', Array(Int32)))))),`
	`453`	`+ ('assignment', Array(Array(Int32))))))),`
`454`	`454`	`('timeout', Int32),`
`455`	`455`	`('validate_only', Boolean)`
`456`	`456`	`)`