consumer_metadata_request_test.go

package sarama

import (
	"testing"
)

var (
	consumerMetadataRequestEmpty = []byte{
		0x00, 0x00}

	consumerMetadataRequestString = []byte{
		0x00, 0x06, 'f', 'o', 'o', 'b', 'a', 'r'}
)

func TestConsumerMetadataRequest(t *testing.T) {
	request := new(ConsumerMetadataRequest)
	testEncodable(t, "empty string", request, consumerMetadataRequestEmpty)
	testVersionDecodable(t, "empty string", request, consumerMetadataRequestEmpty, 0)

	request.ConsumerGroup = "foobar"
	testEncodable(t, "with string", request, consumerMetadataRequestString)
	testVersionDecodable(t, "with string", request, consumerMetadataRequestString, 0)
}