zstd needs client >= 2.1.0.0

functional_producer_test.go

@@ -33,6 +33,7 @@ func TestFuncProducingSnappy(t *testing.T) {
 
 func TestFuncProducingZstd(t *testing.T) {
 	config := NewConfig()
+	config.Version = V2_1_0_0
 	config.Producer.Compression = CompressionZSTD
 	testProducingMessages(t, config)
 }