Function TestCreatePartitionsRequest

create_partitions_request_test.go:51–78

(t *testing.T)

)

func TestCreatePartitionsRequest(t *testing.T) {
	req := &CreatePartitionsRequest{
		TopicPartitions: map[string]*TopicPartition{
			"topic": {
				Count: 3,
			},
		},
		Timeout: 100 * time.Millisecond,
	}

	buf := testRequestEncode(t, "no assignment", req, createPartitionRequestNoAssignment)
	testRequestDecode(t, "no assignment", req, buf)

	req.ValidateOnly = true
	req.TopicPartitions["topic"].Assignment = [][]int32{{2, 3}, {3, 1}}

	buf = testRequestEncode(t, "assignment", req, createPartitionRequestAssignment)
	testRequestDecode(t, "assignment", req, buf)

	req.Version = 2
	buf = testRequestEncode(t, "assignment v2", req, createPartitionRequestAssignmentV2)
	testRequestDecode(t, "assignment v2", req, buf)

	// v3 wire format is identical to v2
	req.Version = 3
	buf = testRequestEncode(t, "assignment v3", req, createPartitionRequestAssignmentV2)
	testRequestDecode(t, "assignment v3", req, buf)
}