delete_offsets_request_test.go

package sarama

import "testing"

var (
	emptyDeleteOffsetsRequest = []byte{
		0, 3, 'f', 'o', 'o', // group name: foo
		0, 0, 0, 0, // 0 partition
	}
)

func TestDeleteOffsetsRequest(t *testing.T) {
	var request *DeleteOffsetsRequest

	request = new(DeleteOffsetsRequest)
	request.Group = "foo"

	testRequest(t, "no offset", request, emptyDeleteOffsetsRequest)

	request = new(DeleteOffsetsRequest)
	request.Group = "foo"
	request.AddPartition("bar", 6)
	request.AddPartition("bar", 7)
	// The response encoded form cannot be checked for it varies due to
	// unpredictable map traversal order.
	testRequest(t, "two offsets on one topic", request, nil)

	request = new(DeleteOffsetsRequest)
	request.Group = "foo"
	request.AddPartition("bar", 6)
	request.AddPartition("bar", 7)
	request.AddPartition("baz", 0)
	// The response encoded form cannot be checked for it varies due to
	// unpredictable map traversal order.
	testRequest(t, "three offsets on two topics", request, nil)
}