diff --git a/Cargo.lock b/Cargo.lock
index e4221b3..d43fc81 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -1401,16 +1401,16 @@ dependencies = [
  "derive_builder",
  "dirs 6.0.0",
  "event-listener 5.4.0",
- "fluvio-compression",
+ "fluvio-compression 0.3.5",
  "fluvio-future",
- "fluvio-protocol",
+ "fluvio-protocol 0.12.4",
  "fluvio-sc-schema",
  "fluvio-smartengine",
- "fluvio-smartmodule",
+ "fluvio-smartmodule 0.8.0",
  "fluvio-socket",
  "fluvio-spu-schema",
  "fluvio-stream-dispatcher",
- "fluvio-types",
+ "fluvio-types 0.5.4",
  "futures-util",
  "once_cell",
  "pin-project",
@@ -1431,7 +1431,7 @@ source = "git+https://github.com/infinyon/fluvio?tag=v0.17.3#411fe8fd930f1e9b78d
 dependencies = [
  "bytes",
  "flate2",
- "fluvio-types",
+ "fluvio-types 0.5.4",
  "lz4_flex",
  "serde",
  "snap",
@@ -1439,6 +1439,17 @@ dependencies = [
  "zstd",
 ]
 
+[[package]]
+name = "fluvio-compression"
+version = "0.50.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.18.1#6450ad5076b35bf1a26f2cc0145fb18a4e7edbb6"
+dependencies = [
+ "bytes",
+ "fluvio-types 0.50.1",
+ "serde",
+ "thiserror 2.0.12",
+]
+
 [[package]]
 name = "fluvio-connector-common"
 version = "0.0.0"
@@ -1483,11 +1494,11 @@ dependencies = [
  "bytesize-serde",
  "fluvio-controlplane-metadata",
  "fluvio-smartengine",
- "fluvio-types",
+ "fluvio-types 0.5.4",
  "humantime-serde",
  "minijinja",
  "openapiv3",
- "schemars",
+ "schemars 0.8.22",
  "serde",
  "serde_yaml",
  "toml",
@@ -1506,13 +1517,13 @@ dependencies = [
  "cfg-if",
  "derive_builder",
  "flate2",
- "fluvio-protocol",
+ "fluvio-protocol 0.12.4",
  "fluvio-stream-model",
- "fluvio-types",
+ "fluvio-types 0.5.4",
  "flv-util",
  "humantime-serde",
  "lenient_semver",
- "schemars",
+ "schemars 0.8.22",
  "semver",
  "serde",
  "serde_yaml",
@@ -1563,10 +1574,10 @@ dependencies = [
  "content_inspector",
  "crc32c",
  "eyre",
- "fluvio-compression",
+ "fluvio-compression 0.3.5",
  "fluvio-future",
- "fluvio-protocol-derive",
- "fluvio-types",
+ "fluvio-protocol-derive 0.5.4",
+ "fluvio-types 0.5.4",
  "flv-util",
  "once_cell",
  "semver",
@@ -1575,6 +1586,26 @@ dependencies = [
  "tracing",
 ]
 
+[[package]]
+name = "fluvio-protocol"
+version = "0.50.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.18.1#6450ad5076b35bf1a26f2cc0145fb18a4e7edbb6"
+dependencies = [
+ "bytes",
+ "cfg-if",
+ "content_inspector",
+ "crc32c",
+ "eyre",
+ "fluvio-compression 0.50.1",
+ "fluvio-protocol-derive 0.50.1",
+ "fluvio-types 0.50.1",
+ "flv-util",
+ "once_cell",
+ "semver",
+ "thiserror 2.0.12",
+ "tracing",
+]
+
 [[package]]
 name = "fluvio-protocol-derive"
 version = "0.5.4"
@@ -1586,6 +1617,17 @@ dependencies = [
  "tracing",
 ]
 
+[[package]]
+name = "fluvio-protocol-derive"
+version = "0.50.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.18.1#6450ad5076b35bf1a26f2cc0145fb18a4e7edbb6"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 1.0.109",
+ "tracing",
+]
+
 [[package]]
 name = "fluvio-sc-schema"
 version = "0.26.0"
@@ -1593,7 +1635,7 @@ source = "git+https://github.com/infinyon/fluvio?tag=v0.17.3#411fe8fd930f1e9b78d
 dependencies = [
  "anyhow",
  "fluvio-controlplane-metadata",
- "fluvio-protocol",
+ "fluvio-protocol 0.12.4",
  "fluvio-socket",
  "fluvio-stream-model",
  "paste",
@@ -1611,10 +1653,10 @@ dependencies = [
  "cfg-if",
  "derive_builder",
  "fluvio-future",
- "fluvio-protocol",
- "fluvio-smartmodule",
+ "fluvio-protocol 0.12.4",
+ "fluvio-smartmodule 0.8.0",
  "humantime-serde",
- "schemars",
+ "schemars 0.8.22",
  "serde",
  "serde_json",
  "serde_yaml",
@@ -1630,8 +1672,20 @@ version = "0.8.0"
 source = "git+https://github.com/infinyon/fluvio?tag=v0.17.3#411fe8fd930f1e9b78d836adf8a0e98635e8436b"
 dependencies = [
  "eyre",
- "fluvio-protocol",
- "fluvio-smartmodule-derive",
+ "fluvio-protocol 0.12.4",
+ "fluvio-smartmodule-derive 0.6.4",
+ "thiserror 2.0.12",
+ "tracing",
+]
+
+[[package]]
+name = "fluvio-smartmodule"
+version = "0.50.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.18.1#6450ad5076b35bf1a26f2cc0145fb18a4e7edbb6"
+dependencies = [
+ "eyre",
+ "fluvio-protocol 0.50.1",
+ "fluvio-smartmodule-derive 0.50.1",
  "thiserror 2.0.12",
  "tracing",
 ]
@@ -1646,6 +1700,16 @@ dependencies = [
  "syn 2.0.89",
 ]
 
+[[package]]
+name = "fluvio-smartmodule-derive"
+version = "0.50.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.18.1#6450ad5076b35bf1a26f2cc0145fb18a4e7edbb6"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 2.0.89",
+]
+
 [[package]]
 name = "fluvio-socket"
 version = "0.15.2"
@@ -1659,7 +1723,7 @@ dependencies = [
  "cfg-if",
  "event-listener 5.4.0",
  "fluvio-future",
- "fluvio-protocol",
+ "fluvio-protocol 0.12.4",
  "futures-util",
  "nix",
  "once_cell",
@@ -1681,9 +1745,9 @@ dependencies = [
  "educe",
  "flate2",
  "fluvio-future",
- "fluvio-protocol",
- "fluvio-smartmodule",
- "fluvio-types",
+ "fluvio-protocol 0.12.4",
+ "fluvio-smartmodule 0.8.0",
+ "fluvio-types 0.5.4",
  "serde",
  "static_assertions",
  "tracing",
@@ -1701,7 +1765,7 @@ dependencies = [
  "cfg-if",
  "fluvio-future",
  "fluvio-stream-model",
- "fluvio-types",
+ "fluvio-types 0.5.4",
  "futures-util",
  "once_cell",
  "parking_lot 0.12.3",
@@ -1731,7 +1795,19 @@ version = "0.5.4"
 source = "git+https://github.com/infinyon/fluvio?tag=v0.17.3#411fe8fd930f1e9b78d836adf8a0e98635e8436b"
 dependencies = [
  "event-listener 5.4.0",
- "schemars",
+ "schemars 0.8.22",
+ "serde",
+ "thiserror 2.0.12",
+ "toml",
+ "tracing",
+]
+
+[[package]]
+name = "fluvio-types"
+version = "0.50.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.18.1#6450ad5076b35bf1a26f2cc0145fb18a4e7edbb6"
+dependencies = [
+ "schemars 1.1.0",
  "serde",
  "thiserror 2.0.12",
  "toml",
@@ -2574,7 +2650,7 @@ version = "0.0.0"
 dependencies = [
  "eyre",
  "fluvio-model-sql",
- "fluvio-smartmodule",
+ "fluvio-smartmodule 0.50.1",
  "once_cell",
  "serde",
  "serde_json",
@@ -3364,6 +3440,26 @@ dependencies = [
  "thiserror 2.0.12",
 ]
 
+[[package]]
+name = "ref-cast"
+version = "1.0.25"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f354300ae66f76f1c85c5f84693f0ce81d747e2c3f21a45fef496d89c960bf7d"
+dependencies = [
+ "ref-cast-impl",
+]
+
+[[package]]
+name = "ref-cast-impl"
+version = "1.0.25"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b7186006dcb21920990093f30e3dea63b7d6e977bf1256be20c3563a5db070da"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 2.0.89",
+]
+
 [[package]]
 name = "regalloc2"
 version = "0.11.2"
@@ -3614,7 +3710,20 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "3fbf2ae1b8bc8e02df939598064d22402220cd5bbcca1c76f7d6a310974d5615"
 dependencies = [
  "dyn-clone",
- "schemars_derive",
+ "schemars_derive 0.8.22",
+ "serde",
+ "serde_json",
+]
+
+[[package]]
+name = "schemars"
+version = "1.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9558e172d4e8533736ba97870c4b2cd63f84b382a3d6eb063da41b91cce17289"
+dependencies = [
+ "dyn-clone",
+ "ref-cast",
+ "schemars_derive 1.1.0",
  "serde",
  "serde_json",
 ]
@@ -3631,6 +3740,18 @@ dependencies = [
  "syn 2.0.89",
 ]
 
+[[package]]
+name = "schemars_derive"
+version = "1.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "301858a4023d78debd2353c7426dc486001bddc91ae31a76fb1f55132f7e2633"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "serde_derive_internals",
+ "syn 2.0.89",
+]
+
 [[package]]
 name = "scopeguard"
 version = "1.2.0"
@@ -5235,7 +5356,7 @@ version = "0.1.9"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "cf221c93e13a30d793f7645a0e7762c55d169dbb0a49671918a2319d289b10bb"
 dependencies = [
- "windows-sys 0.59.0",
+ "windows-sys 0.48.0",
 ]
 
 [[package]]