Makes Assignments nullable in createpartitions RequestTopic (#758)

Author: rhansen2

createpartitions_test.go

@@ -33,7 +33,36 @@ func TestClientCreatePartitions(t *testing.T) {
 		},
 		ValidateOnly: false,
 	})
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	if err := res.Errors[topic]; err != nil {
+		t.Error(err)
+	}
+}
+
+func TestClientCreatePartitionsNoAssignments(t *testing.T) {
+	if !ktesting.KafkaIsAtLeast("1.0.1") {
+		return
+	}
+
+	client, shutdown := newLocalClient()
+	defer shutdown()
 
+	topic := makeTopic()
+	createTopic(t, topic, 1)
+	defer deleteTopic(t, topic)
+
+	res, err := client.CreatePartitions(context.Background(), &CreatePartitionsRequest{
+		Topics: []TopicPartitionsConfig{
+			{
+				Name:  topic,
+				Count: 2,
+			},
+		},
+		ValidateOnly: false,
+	})
 	if err != nil {
 		t.Fatal(err)
 	}

protocol/createpartitions/createpartitions.go

@@ -23,7 +23,7 @@ func (r *Request) Broker(cluster protocol.Cluster) (protocol.Broker, error) {
 type RequestTopic struct {
 	Name        string              `kafka:"min=v0,max=v1"`
 	Count       int32               `kafka:"min=v0,max=v1"`
-	Assignments []RequestAssignment `kafka:"min=v0,max=v1"`
+	Assignments []RequestAssignment `kafka:"min=v0,max=v1,nullable"`
 }
 
 type RequestAssignment struct {
@@ -43,6 +43,4 @@ type ResponseResult struct {
 	ErrorMessage string `kafka:"min=v0,max=v1,nullable"`
 }
 
-var (
-	_ protocol.BrokerMessage = (*Request)(nil)
-)
+var _ protocol.BrokerMessage = (*Request)(nil)