Function TestFuncProducingSnappy

functional_producer_test.go:37–41

(t *testing.T)

}

func TestFuncProducingSnappy(t *testing.T) {
	config := NewFunctionalTestConfig()
	config.Producer.Compression = CompressionSnappy
	testProducingMessages(t, config, MinVersion)
}

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