feat(conn-pkg): use types for compression in conn pkg

crates/fluvio-connector-common/src/producer.rs

@@ -18,8 +18,8 @@ pub async fn producer_from_config(config: &ConnectorConfig) -> Result<(Fluvio, T
         };
 
         // Compression
-        if let Some(compression) = producer_params.compression {
-            config_builder = config_builder.compression(compression)
+        if let Some(compression) = &producer_params.compression {
+            config_builder = config_builder.compression(compression.clone())
         };
 
         // Batch size

crates/fluvio-connector-package/Cargo.toml

@@ -28,7 +28,6 @@ fluvio-controlplane-metadata = { path = "../fluvio-controlplane-metadata/", defa
 fluvio-smartengine = { path = "../fluvio-smartengine", default-features = false, features = [
     "transformation",
 ] }
-fluvio-compression = { path = "../fluvio-compression" }
 fluvio-types = { path = "../fluvio-types" }
 bytesize-serde = "0.2.1"
 

crates/fluvio-connector-package/src/config/mod.rs

@@ -15,8 +15,8 @@ pub use bytesize::ByteSize;
 
 pub use fluvio_controlplane_metadata::topic::config as topic_config;
 pub use fluvio_smartengine::transformation::TransformationStep;
-pub use fluvio_compression::Compression;
 pub use fluvio_types::PartitionId;
+pub use fluvio_types::compression::Compression;
 
 use crate::metadata::Direction;
 

crates/fluvio-types/Cargo.toml

@@ -14,7 +14,7 @@ events = ["event-listener"]
 event-listener = { workspace = true,  optional = true }
 thiserror = { workspace = true }
 tracing = { workspace = true }
-serde = { workspace = true }
+serde = { workspace = true, features = ["derive"], default-features = false }
 toml = { workspace = true, features = ["display", "preserve_order", "parse"] }
 
 [dev-dependencies]

crates/fluvio-types/src/compression.rs

@@ -1,4 +1,7 @@
-#[derive(Clone, Debug, Eq, PartialEq)]
+use serde::{Serialize, Deserialize};
+
+#[derive(Clone, Debug, Deserialize, Eq, Serialize, PartialEq)]
+#[serde(rename_all = "lowercase")]
 pub enum Compression {
     None,
     Gzip,