Function runTestFuncConsumerGroupMember

functional_consumer_group_test.go:414–426

(
	t *testing.T,
	groupID string,
	clientID string,
	maxMessages int32,
	sink *testFuncConsumerGroupSink,
	topics ...string,
)

}

func runTestFuncConsumerGroupMember(
	t *testing.T,
	groupID string,
	clientID string,
	maxMessages int32,
	sink *testFuncConsumerGroupSink,
	topics ...string,
) *testFuncConsumerGroupMember {
	t.Helper()

	config := defaultConfig(clientID)
	return runTestFuncConsumerGroupMemberWithConfig(t, config, groupID, maxMessages, sink, topics...)
}

func runTestFuncConsumerGroupMemberWithConfig(
	t *testing.T,