Function TestFuncProducingNoResponse

functional_producer_test.go:49–54

(t *testing.T)

}

func TestFuncProducingNoResponse(t *testing.T) {
	config := NewFunctionalTestConfig()
	config.ApiVersionsRequest = false
	config.Producer.RequiredAcks = NoResponse
	testProducingMessages(t, config, MinVersion)
}

func TestFuncProducingFlushing(t *testing.T) {
	config := NewFunctionalTestConfig()