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) }