sarama/alter_partition_reassignments_response_test.go

package sarama

import "testing"

var (
	alterPartitionReassignmentsResponseNoError = []byte{
		0, 0, 39, 16, // ThrottleTimeMs 10000
		0, 0, // errorcode
		0, // null string
		1, // empty errors array
		0, // empty tagged fields
	}

	alterPartitionReassignmentsResponseWithError = []byte{
		0, 0, 39, 16, // ThrottleTimeMs 10000
		0, 12, // errorcode
		6, 101, 114, 114, 111, 114, // error string "error"
		2,                         // errors array length 1
		6, 116, 111, 112, 105, 99, // topic name "topic"
		2,          // partition array length 1
		0, 0, 0, 1, // partitionId
		0, 3, //kerror
		7, 101, 114, 114, 111, 114, 50, // error string "error2"
		0, 0, 0, // empty tagged fields
	}
)

func TestAlterPartitionReassignmentResponse(t *testing.T) {
	var response *AlterPartitionReassignmentsResponse

	response = &AlterPartitionReassignmentsResponse{
		ThrottleTimeMs: int32(10000),
		Version:        int16(0),
	}

	testResponse(t, "no error", response, alterPartitionReassignmentsResponseNoError)

	errorMessage := "error"
	partitionError := "error2"
	response.ErrorCode = 12
	response.ErrorMessage = &errorMessage
	response.AddError("topic", 1, 3, &partitionError)

	testResponse(t, "with error", response, alterPartitionReassignmentsResponseWithError)
}