Function BenchmarkProducerMediumSnappy

functional_producer_test.go:1283–1287

(b *testing.B)

}

func BenchmarkProducerMediumSnappy(b *testing.B) {
	conf := NewFunctionalTestConfig()
	conf.Producer.Compression = CompressionSnappy
	benchmarkProducer(b, conf, "test.1", ByteEncoder(make([]byte, 1024)))
}

func benchmarkProducer(b *testing.B, conf *Config, topic string, value Encoder) {
	setupFunctionalTest(b)