sarama/find_coordinator_request_test.go

package sarama

import "testing"

var (
	findCoordinatorRequestConsumerGroup = []byte{
		0, 5, 'g', 'r', 'o', 'u', 'p',
		0,
	}

	findCoordinatorRequestTransaction = []byte{
		0, 13, 't', 'r', 'a', 'n', 's', 'a', 'c', 't', 'i', 'o', 'n', 'i', 'd',
		1,
	}
)

func TestFindCoordinatorRequest(t *testing.T) {
	req := &FindCoordinatorRequest{
		Version:         1,
		CoordinatorKey:  "group",
		CoordinatorType: CoordinatorGroup,
	}

	testRequest(t, "version 1 - group", req, findCoordinatorRequestConsumerGroup)

	req = &FindCoordinatorRequest{
		Version:         1,
		CoordinatorKey:  "transactionid",
		CoordinatorType: CoordinatorTransaction,
	}

	testRequest(t, "version 1 - transaction", req, findCoordinatorRequestTransaction)
}