Function expectResults

async_producer_test.go:59–61

(t *testing.T, p AsyncProducer, successCount, errorCount int)

}

func expectResults(t *testing.T, p AsyncProducer, successCount, errorCount int) {
	expectResultsWithTimeout(t, p, successCount, errorCount, 5*time.Minute)
}

func TestPartitionProducerFlushRetryBuffersAssignsSequence(t *testing.T) {
	cfg := NewTestConfig()