include zstd on the functional tests

functional_producer_test.go

@@ -31,6 +31,12 @@ func TestFuncProducingSnappy(t *testing.T) {
 	testProducingMessages(t, config)
 }
 
+func TestFuncProducingZstd(t *testing.T) {
+	config := NewConfig()
+	config.Producer.Compression = CompressionZSTD
+	testProducingMessages(t, config)
+}
+
 func TestFuncProducingNoResponse(t *testing.T) {
 	config := NewConfig()
 	config.Producer.RequiredAcks = NoResponse