diff --git a/Cargo.lock b/Cargo.lock
index 152e62c..f9c4e3f 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -188,6 +188,21 @@ dependencies = [
  "tokio",
 ]
 
+[[package]]
+name = "async-global-executor"
+version = "3.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "13f937e26114b93193065fd44f507aa2e9169ad0cdabbb996920b1fe1ddea7ba"
+dependencies = [
+ "async-channel 2.3.1",
+ "async-executor",
+ "async-io",
+ "async-lock",
+ "blocking",
+ "futures-lite",
+ "tokio",
+]
+
 [[package]]
 name = "async-io"
 version = "2.4.0"
@@ -274,7 +289,7 @@ checksum = "730294c1c08c2e0f85759590518f6333f0d5a0a766a27d519c1b244c3dfd8a24"
 dependencies = [
  "async-attributes",
  "async-channel 1.9.0",
- "async-global-executor",
+ "async-global-executor 2.4.1",
  "async-io",
  "async-lock",
  "async-process",
@@ -352,6 +367,29 @@ version = "1.4.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "ace50bade8e6234aa140d9a2f552bbee1db4d353f69b8217bc503490fc1a9f26"
 
+[[package]]
+name = "aws-lc-rs"
+version = "1.13.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "93fcc8f365936c834db5514fc45aee5b1202d677e6b40e48468aaaa8183ca8c7"
+dependencies = [
+ "aws-lc-sys",
+ "zeroize",
+]
+
+[[package]]
+name = "aws-lc-sys"
+version = "0.29.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "61b1d86e7705efe1be1b569bab41d4fa1e14e220b60a160f78de2db687add079"
+dependencies = [
+ "bindgen",
+ "cc",
+ "cmake",
+ "dunce",
+ "fs_extra",
+]
+
 [[package]]
 name = "backtrace"
 version = "0.3.75"
@@ -379,6 +417,29 @@ version = "0.22.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "72b3254f16251a8381aa12e40e3c4d2f0199f8c6508fbecb9d91f575e0fbb8c6"
 
+[[package]]
+name = "bindgen"
+version = "0.69.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "271383c67ccabffb7381723dea0672a673f292304fcb45c01cc648c7a8d58088"
+dependencies = [
+ "bitflags 2.9.1",
+ "cexpr",
+ "clang-sys",
+ "itertools",
+ "lazy_static",
+ "lazycell",
+ "log",
+ "prettyplease",
+ "proc-macro2",
+ "quote",
+ "regex",
+ "rustc-hash 1.1.0",
+ "shlex",
+ "syn 2.0.101",
+ "which",
+]
+
 [[package]]
 name = "bitflags"
 version = "1.3.2"
@@ -580,6 +641,15 @@ dependencies = [
  "shlex",
 ]
 
+[[package]]
+name = "cexpr"
+version = "0.6.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6fac387a98bb7c37292057cffc56d62ecb629900026402633ae9160df93a8766"
+dependencies = [
+ "nom",
+]
+
 [[package]]
 name = "cfg-if"
 version = "1.0.0"
@@ -607,6 +677,26 @@ dependencies = [
  "windows-link",
 ]
 
+[[package]]
+name = "clang-sys"
+version = "1.8.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0b023947811758c97c59bf9d1c188fd619ad4718dcaa767947df1cadb14f39f4"
+dependencies = [
+ "glob",
+ "libc",
+ "libloading",
+]
+
+[[package]]
+name = "cmake"
+version = "0.1.54"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e7caa3f9de89ddbe2c607f4101924c5abec803763ae9534e4f4d7d8f84aa81f0"
+dependencies = [
+ "cc",
+]
+
 [[package]]
 name = "cobs"
 version = "0.2.3"
@@ -725,7 +815,7 @@ dependencies = [
  "log",
  "pulley-interpreter",
  "regalloc2",
- "rustc-hash",
+ "rustc-hash 2.1.1",
  "serde",
  "smallvec",
  "target-lexicon",
@@ -1034,6 +1124,12 @@ dependencies = [
  "syn 2.0.101",
 ]
 
+[[package]]
+name = "dunce"
+version = "1.0.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "92773504d58c093f6de2459af4af33faa518c13451eb8f2b5698ed3d36e7c813"
+
 [[package]]
 name = "dyn-clone"
 version = "1.0.19"
@@ -1233,16 +1329,16 @@ dependencies = [
  "derive_builder",
  "dirs 6.0.0",
  "event-listener 5.4.0",
- "fluvio-compression",
- "fluvio-future",
- "fluvio-protocol",
- "fluvio-sc-schema",
+ "fluvio-compression 0.3.5",
+ "fluvio-future 0.7.2",
+ "fluvio-protocol 0.12.4",
+ "fluvio-sc-schema 0.26.0",
  "fluvio-smartengine",
- "fluvio-smartmodule",
- "fluvio-socket",
- "fluvio-spu-schema",
- "fluvio-stream-dispatcher",
- "fluvio-types",
+ "fluvio-smartmodule 0.8.0",
+ "fluvio-socket 0.15.2",
+ "fluvio-spu-schema 0.18.0",
+ "fluvio-stream-dispatcher 0.13.7",
+ "fluvio-types 0.5.4",
  "futures-util",
  "once_cell",
  "pin-project",
@@ -1256,6 +1352,45 @@ dependencies = [
  "web-time",
 ]
 
+[[package]]
+name = "fluvio"
+version = "0.50.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.18.1#6450ad5076b35bf1a26f2cc0145fb18a4e7edbb6"
+dependencies = [
+ "adaptive_backoff",
+ "anyhow",
+ "async-channel 2.3.1",
+ "async-lock",
+ "async-trait",
+ "cfg-if",
+ "chrono",
+ "derive_builder",
+ "dirs 6.0.0",
+ "event-listener 5.4.0",
+ "fluvio-compression 0.50.1",
+ "fluvio-future 0.8.3",
+ "fluvio-protocol 0.50.1",
+ "fluvio-sc-schema 0.50.1",
+ "fluvio-smartmodule 0.50.1",
+ "fluvio-socket 0.50.1",
+ "fluvio-spu-schema 0.50.1",
+ "fluvio-stream-dispatcher 0.50.1",
+ "fluvio-types 0.50.1",
+ "futures-util",
+ "once_cell",
+ "parking_lot 0.12.3",
+ "pin-project",
+ "rustls 0.23.28",
+ "semver",
+ "serde",
+ "siphasher",
+ "thiserror 2.0.12",
+ "tokio",
+ "toml",
+ "tracing",
+ "web-time",
+]
+
 [[package]]
 name = "fluvio-compression"
 version = "0.3.5"
@@ -1263,7 +1398,22 @@ 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",
+ "thiserror 2.0.12",
+ "zstd",
+]
+
+[[package]]
+name = "fluvio-compression"
+version = "0.50.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.18.1#6450ad5076b35bf1a26f2cc0145fb18a4e7edbb6"
+dependencies = [
+ "bytes",
+ "flate2",
+ "fluvio-types 0.50.1",
  "lz4_flex",
  "serde",
  "snap",
@@ -1280,11 +1430,11 @@ dependencies = [
  "async-channel 1.9.0",
  "async-trait",
  "ctrlc",
- "fluvio",
+ "fluvio 0.28.0",
  "fluvio-connector-derive",
  "fluvio-connector-package",
- "fluvio-future",
- "fluvio-sc-schema",
+ "fluvio-future 0.7.2",
+ "fluvio-sc-schema 0.26.0",
  "fluvio-smartengine",
  "futures",
  "futures-util",
@@ -1313,13 +1463,13 @@ dependencies = [
  "anyhow",
  "bytesize",
  "bytesize-serde",
- "fluvio-controlplane-metadata",
+ "fluvio-controlplane-metadata 0.31.0",
  "fluvio-smartengine",
- "fluvio-types",
+ "fluvio-types 0.5.4",
  "humantime-serde",
  "minijinja",
  "openapiv3",
- "schemars",
+ "schemars 0.8.22",
  "serde",
  "serde_yaml",
  "toml",
@@ -1338,13 +1488,40 @@ dependencies = [
  "cfg-if",
  "derive_builder",
  "flate2",
- "fluvio-protocol",
- "fluvio-stream-model",
- "fluvio-types",
+ "fluvio-protocol 0.12.4",
+ "fluvio-stream-model 0.11.5",
+ "fluvio-types 0.5.4",
  "flv-util",
  "humantime-serde",
  "lenient_semver",
- "schemars",
+ "schemars 0.8.22",
+ "semver",
+ "serde",
+ "serde_yaml",
+ "thiserror 2.0.12",
+ "toml",
+ "tracing",
+]
+
+[[package]]
+name = "fluvio-controlplane-metadata"
+version = "0.50.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.18.1#6450ad5076b35bf1a26f2cc0145fb18a4e7edbb6"
+dependencies = [
+ "anyhow",
+ "base64 0.22.1",
+ "bytes",
+ "bytesize",
+ "cfg-if",
+ "derive_builder",
+ "flate2",
+ "fluvio-protocol 0.50.1",
+ "fluvio-stream-model 0.50.1",
+ "fluvio-types 0.50.1",
+ "flv-util",
+ "humantime-serde",
+ "lenient_semver",
+ "schemars 1.0.4",
  "semver",
  "serde",
  "serde_yaml",
@@ -1378,6 +1555,33 @@ dependencies = [
  "ws_stream_wasm",
 ]
 
+[[package]]
+name = "fluvio-future"
+version = "0.8.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "404e1beb0ba16331eb7b82b4e4e586f03e7de9438368880a3b9870f53105b2b0"
+dependencies = [
+ "anyhow",
+ "async-global-executor 3.1.0",
+ "async-io",
+ "async-net",
+ "async-task",
+ "async-trait",
+ "cfg-if",
+ "fluvio-wasm-timer",
+ "futures-lite",
+ "futures-rustls",
+ "futures-util",
+ "pin-project",
+ "rustls-pemfile",
+ "socket2",
+ "thiserror 2.0.12",
+ "tokio",
+ "tracing",
+ "wasm-bindgen-futures",
+ "ws_stream_wasm",
+]
+
 [[package]]
 name = "fluvio-protocol"
 version = "0.12.4"
@@ -1388,10 +1592,32 @@ dependencies = [
  "content_inspector",
  "crc32c",
  "eyre",
- "fluvio-compression",
- "fluvio-future",
- "fluvio-protocol-derive",
- "fluvio-types",
+ "fluvio-compression 0.3.5",
+ "fluvio-future 0.7.2",
+ "fluvio-protocol-derive 0.5.4",
+ "fluvio-types 0.5.4",
+ "flv-util",
+ "once_cell",
+ "semver",
+ "thiserror 2.0.12",
+ "tokio-util",
+ "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-future 0.8.3",
+ "fluvio-protocol-derive 0.50.1",
+ "fluvio-types 0.50.1",
  "flv-util",
  "once_cell",
  "semver",
@@ -1411,16 +1637,43 @@ 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"
 source = "git+https://github.com/infinyon/fluvio?tag=v0.17.3#411fe8fd930f1e9b78d836adf8a0e98635e8436b"
 dependencies = [
  "anyhow",
- "fluvio-controlplane-metadata",
- "fluvio-protocol",
- "fluvio-socket",
- "fluvio-stream-model",
+ "fluvio-controlplane-metadata 0.31.0",
+ "fluvio-protocol 0.12.4",
+ "fluvio-socket 0.15.2",
+ "fluvio-stream-model 0.11.5",
+ "paste",
+ "static_assertions",
+ "thiserror 2.0.12",
+ "tracing",
+]
+
+[[package]]
+name = "fluvio-sc-schema"
+version = "0.50.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.18.1#6450ad5076b35bf1a26f2cc0145fb18a4e7edbb6"
+dependencies = [
+ "anyhow",
+ "fluvio-controlplane-metadata 0.50.1",
+ "fluvio-protocol 0.50.1",
+ "fluvio-socket 0.50.1",
+ "fluvio-stream-model 0.50.1",
  "paste",
  "static_assertions",
  "thiserror 2.0.12",
@@ -1435,11 +1688,11 @@ dependencies = [
  "anyhow",
  "cfg-if",
  "derive_builder",
- "fluvio-future",
- "fluvio-protocol",
- "fluvio-smartmodule",
+ "fluvio-future 0.7.2",
+ "fluvio-protocol 0.12.4",
+ "fluvio-smartmodule 0.8.0",
  "humantime-serde",
- "schemars",
+ "schemars 0.8.22",
  "serde",
  "serde_json",
  "serde_yaml",
@@ -1455,8 +1708,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",
 ]
@@ -1471,6 +1736,16 @@ dependencies = [
  "syn 2.0.101",
 ]
 
+[[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.101",
+]
+
 [[package]]
 name = "fluvio-socket"
 version = "0.15.2"
@@ -1483,8 +1758,33 @@ dependencies = [
  "bytes",
  "cfg-if",
  "event-listener 5.4.0",
- "fluvio-future",
- "fluvio-protocol",
+ "fluvio-future 0.7.2",
+ "fluvio-protocol 0.12.4",
+ "futures-util",
+ "nix 0.29.0",
+ "once_cell",
+ "pin-project",
+ "semver",
+ "thiserror 2.0.12",
+ "tokio",
+ "tokio-util",
+ "tracing",
+]
+
+[[package]]
+name = "fluvio-socket"
+version = "0.50.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.18.1#6450ad5076b35bf1a26f2cc0145fb18a4e7edbb6"
+dependencies = [
+ "async-channel 2.3.1",
+ "async-lock",
+ "async-trait",
+ "built",
+ "bytes",
+ "cfg-if",
+ "event-listener 5.4.0",
+ "fluvio-future 0.8.3",
+ "fluvio-protocol 0.50.1",
  "futures-util",
  "nix 0.29.0",
  "once_cell",
@@ -1505,10 +1805,28 @@ dependencies = [
  "derive_builder",
  "educe",
  "flate2",
- "fluvio-future",
- "fluvio-protocol",
- "fluvio-smartmodule",
- "fluvio-types",
+ "fluvio-future 0.7.2",
+ "fluvio-protocol 0.12.4",
+ "fluvio-smartmodule 0.8.0",
+ "fluvio-types 0.5.4",
+ "serde",
+ "static_assertions",
+ "tracing",
+]
+
+[[package]]
+name = "fluvio-spu-schema"
+version = "0.50.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.18.1#6450ad5076b35bf1a26f2cc0145fb18a4e7edbb6"
+dependencies = [
+ "bytes",
+ "derive_builder",
+ "educe",
+ "flate2",
+ "fluvio-future 0.8.3",
+ "fluvio-protocol 0.50.1",
+ "fluvio-smartmodule 0.50.1",
+ "fluvio-types 0.50.1",
  "serde",
  "static_assertions",
  "tracing",
@@ -1524,9 +1842,32 @@ dependencies = [
  "async-lock",
  "async-trait",
  "cfg-if",
- "fluvio-future",
- "fluvio-stream-model",
- "fluvio-types",
+ "fluvio-future 0.7.2",
+ "fluvio-stream-model 0.11.5",
+ "fluvio-types 0.5.4",
+ "futures-util",
+ "once_cell",
+ "parking_lot 0.12.3",
+ "serde",
+ "serde_yaml",
+ "tempfile",
+ "tokio",
+ "tracing",
+]
+
+[[package]]
+name = "fluvio-stream-dispatcher"
+version = "0.50.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.18.1#6450ad5076b35bf1a26f2cc0145fb18a4e7edbb6"
+dependencies = [
+ "anyhow",
+ "async-channel 2.3.1",
+ "async-lock",
+ "async-trait",
+ "cfg-if",
+ "fluvio-future 0.8.3",
+ "fluvio-stream-model 0.50.1",
+ "fluvio-types 0.50.1",
  "futures-util",
  "once_cell",
  "parking_lot 0.12.3",
@@ -1544,7 +1885,20 @@ source = "git+https://github.com/infinyon/fluvio?tag=v0.17.3#411fe8fd930f1e9b78d
 dependencies = [
  "async-lock",
  "event-listener 5.4.0",
- "k8-types",
+ "k8-types 0.8.8",
+ "once_cell",
+ "serde",
+ "tracing",
+]
+
+[[package]]
+name = "fluvio-stream-model"
+version = "0.50.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.18.1#6450ad5076b35bf1a26f2cc0145fb18a4e7edbb6"
+dependencies = [
+ "async-lock",
+ "event-listener 5.4.0",
+ "k8-types 0.9.0",
  "once_cell",
  "serde",
  "tracing",
@@ -1556,7 +1910,20 @@ 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 = [
+ "event-listener 5.4.0",
+ "schemars 1.0.4",
  "serde",
  "thiserror 2.0.12",
  "toml",
@@ -1635,6 +2002,12 @@ dependencies = [
  "windows-sys 0.59.0",
 ]
 
+[[package]]
+name = "fs_extra"
+version = "1.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "42703706b716c37f96a77aea830392ad231f44c9e9a67872fa5548707e11b11c"
+
 [[package]]
 name = "futures"
 version = "0.3.31"
@@ -1707,6 +2080,17 @@ dependencies = [
  "syn 2.0.101",
 ]
 
+[[package]]
+name = "futures-rustls"
+version = "0.26.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a8f2f12607f92c69b12ed746fabf9ca4f5c482cba46679c1a75b874ed7c26adb"
+dependencies = [
+ "futures-io",
+ "rustls 0.23.28",
+ "rustls-pki-types",
+]
+
 [[package]]
 name = "futures-sink"
 version = "0.3.31"
@@ -1803,6 +2187,12 @@ dependencies = [
  "stable_deref_trait",
 ]
 
+[[package]]
+name = "glob"
+version = "0.3.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a8d1add55171497b4705a648c6b583acafb01d58050a51727785f0b2c8e0a2b2"
+
 [[package]]
 name = "gloo-timers"
 version = "0.3.0"
@@ -1849,6 +2239,15 @@ version = "0.4.3"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "7f24254aa9a54b5c858eaee2f5bccdb46aaf0e486a595ed5fd8f86ba55232a70"
 
+[[package]]
+name = "home"
+version = "0.5.11"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "589533453244b0995c858700322199b2becb13b627df2851f64a2775d024abcf"
+dependencies = [
+ "windows-sys 0.59.0",
+]
+
 [[package]]
 name = "http"
 version = "1.3.1"
@@ -2172,8 +2571,8 @@ dependencies = [
  "async-std",
  "bollard",
  "env_logger",
- "fluvio",
- "fluvio-future",
+ "fluvio 0.50.1",
+ "fluvio-future 0.7.2",
  "futures-util",
  "log",
  "rumqttc",
@@ -2299,6 +2698,16 @@ dependencies = [
  "serde_json",
 ]
 
+[[package]]
+name = "k8-types"
+version = "0.9.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a03d75bcb5555871dcffa40538fee4e59d38e3d21457c7c19108a31a76a69122"
+dependencies = [
+ "serde",
+ "serde_json",
+]
+
 [[package]]
 name = "kv-log-macro"
 version = "1.0.7"
@@ -2314,6 +2723,12 @@ version = "1.5.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "bbd2bcb4c963f2ddae06a2efc7e9f3591312473c50c6685e1f298068316e66fe"
 
+[[package]]
+name = "lazycell"
+version = "1.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "830d08ce1d1d941e6b30645f1a0eb5643013d835ce3779a5fc208261dbe10f55"
+
 [[package]]
 name = "leb128"
 version = "0.2.5"
@@ -2361,6 +2776,16 @@ version = "0.2.172"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "d750af042f7ef4f724306de029d18836c26c1765a54a6a3f094cbd23a7267ffa"
 
+[[package]]
+name = "libloading"
+version = "0.8.8"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "07033963ba89ebaf1584d767badaa2e8fcec21aedea6b8c0346d487d49c28667"
+dependencies = [
+ "cfg-if",
+ "windows-targets",
+]
+
 [[package]]
 name = "libm"
 version = "0.2.15"
@@ -2472,6 +2897,12 @@ dependencies = [
  "serde",
 ]
 
+[[package]]
+name = "minimal-lexical"
+version = "0.2.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "68354c5c6bd36d73ff3feceb05efa59b6acb7626617f4962be322a825e61f79a"
+
 [[package]]
 name = "miniz_oxide"
 version = "0.8.8"
@@ -2499,11 +2930,11 @@ dependencies = [
  "anyhow",
  "async-std",
  "async-trait",
- "fluvio",
+ "fluvio 0.50.1",
  "fluvio-connector-common",
  "futures",
  "rumqttc",
- "rustls",
+ "rustls 0.22.4",
  "rustls-native-certs",
  "serde",
  "serde_json",
@@ -2536,6 +2967,16 @@ dependencies = [
  "libc",
 ]
 
+[[package]]
+name = "nom"
+version = "7.1.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d273983c5a657a70a3e8f2a01329822f3b8c8172b73826411a55751e404a0a4a"
+dependencies = [
+ "memchr",
+ "minimal-lexical",
+]
+
 [[package]]
 name = "nu-ansi-term"
 version = "0.46.0"
@@ -2853,6 +3294,16 @@ dependencies = [
  "zerocopy",
 ]
 
+[[package]]
+name = "prettyplease"
+version = "0.2.34"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6837b9e10d61f45f987d50808f83d1ee3d206c66acf650c3e4ae2e1f6ddedf55"
+dependencies = [
+ "proc-macro2",
+ "syn 2.0.101",
+]
+
 [[package]]
 name = "proc-macro2"
 version = "1.0.95"
@@ -2987,6 +3438,26 @@ dependencies = [
  "thiserror 2.0.12",
 ]
 
+[[package]]
+name = "ref-cast"
+version = "1.0.24"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "4a0ae411dbe946a674d89546582cea4ba2bb8defac896622d6496f14c23ba5cf"
+dependencies = [
+ "ref-cast-impl",
+]
+
+[[package]]
+name = "ref-cast-impl"
+version = "1.0.24"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1165225c21bff1f3bbce98f5a1f889949bc902d3575308cc7b0de30b4f6d27c7"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 2.0.101",
+]
+
 [[package]]
 name = "regalloc2"
 version = "0.11.2"
@@ -2997,7 +3468,7 @@ dependencies = [
  "bumpalo",
  "hashbrown 0.15.3",
  "log",
- "rustc-hash",
+ "rustc-hash 2.1.1",
  "smallvec",
 ]
 
@@ -3073,7 +3544,7 @@ dependencies = [
  "log",
  "rustls-native-certs",
  "rustls-pemfile",
- "rustls-webpki",
+ "rustls-webpki 0.102.8",
  "thiserror 1.0.69",
  "tokio",
  "tokio-rustls",
@@ -3087,6 +3558,12 @@ version = "0.1.24"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "719b953e2095829ee67db738b3bfa9fa368c94900df327b3f07fe6e794d2fe1f"
 
+[[package]]
+name = "rustc-hash"
+version = "1.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "08d43f7aa6b08d49f382cde6a7982047c3426db949b1424bc4b7ec9ae12c6ce2"
+
 [[package]]
 name = "rustc-hash"
 version = "2.1.1"
@@ -3147,7 +3624,22 @@ dependencies = [
  "log",
  "ring",
  "rustls-pki-types",
- "rustls-webpki",
+ "rustls-webpki 0.102.8",
+ "subtle",
+ "zeroize",
+]
+
+[[package]]
+name = "rustls"
+version = "0.23.28"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7160e3e10bf4535308537f3c4e1641468cd0e485175d6163087c0393c7d46643"
+dependencies = [
+ "aws-lc-rs",
+ "log",
+ "once_cell",
+ "rustls-pki-types",
+ "rustls-webpki 0.103.3",
  "subtle",
  "zeroize",
 ]
@@ -3194,6 +3686,18 @@ dependencies = [
  "untrusted",
 ]
 
+[[package]]
+name = "rustls-webpki"
+version = "0.103.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e4a72fe2bcf7a6ac6fd7d0b9e5cb68aeb7d4c0a0271730218b3e92d43b4eb435"
+dependencies = [
+ "aws-lc-rs",
+ "ring",
+ "rustls-pki-types",
+ "untrusted",
+]
+
 [[package]]
 name = "rustversion"
 version = "1.0.21"
@@ -3222,7 +3726,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.0.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "82d20c4491bc164fa2f6c5d44565947a52ad80b9505d8e36f8d54c27c739fcd0"
+dependencies = [
+ "dyn-clone",
+ "ref-cast",
+ "schemars_derive 1.0.4",
  "serde",
  "serde_json",
 ]
@@ -3239,6 +3756,18 @@ dependencies = [
  "syn 2.0.101",
 ]
 
+[[package]]
+name = "schemars_derive"
+version = "1.0.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "33d020396d1d138dc19f1165df7545479dcd58d93810dc5d646a16e55abefa80"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "serde_derive_internals",
+ "syn 2.0.101",
+]
+
 [[package]]
 name = "scopeguard"
 version = "1.2.0"
@@ -3476,9 +4005,9 @@ checksum = "1b6b67fb9a61334225b5b790716f609cd58395f895b3fe8b328786812a40bc3b"
 
 [[package]]
 name = "socket2"
-version = "0.5.9"
+version = "0.5.10"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "4f5fd57c80058a56cf5c777ab8a126398ece8e442983605d280a44ce79d0edef"
+checksum = "e22376abed350d73dd1cd119b57ffccad95b4e585a7cda43e286245ce23c0678"
 dependencies = [
  "libc",
  "windows-sys 0.52.0",
@@ -3724,7 +4253,7 @@ version = "0.25.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "775e0c0f0adb3a2f22a00c4745d728b479985fc15ee7ca6a2608388c5569860f"
 dependencies = [
- "rustls",
+ "rustls 0.22.4",
  "rustls-pki-types",
  "tokio",
 ]
@@ -3883,7 +4412,7 @@ dependencies = [
  "httparse",
  "log",
  "rand",
- "rustls",
+ "rustls 0.22.4",
  "rustls-pki-types",
  "sha1",
  "thiserror 1.0.69",
@@ -4480,6 +5009,18 @@ dependencies = [
  "wasm-bindgen",
 ]
 
+[[package]]
+name = "which"
+version = "4.4.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "87ba24419a2078cd2b0f2ede2691b6c66d8e47836da3b6db8265ebad47afbfc7"
+dependencies = [
+ "either",
+ "home",
+ "once_cell",
+ "rustix 0.38.44",
+]
+
 [[package]]
 name = "wiggle"
 version = "31.0.0"
diff --git a/Cargo.toml b/Cargo.toml
index 1963078..7ddb5b2 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -48,7 +48,7 @@ serde = {version = "1.0", default-features = false }
 rumqttc = { version = "0.24" }
 rustls = { version = "0.22" }
 
-fluvio = { git = "https://github.com/infinyon/fluvio", tag = "v0.17.3" }
+fluvio = { git = "https://github.com/infinyon/fluvio", tag = "v0.18.1" }
 fluvio-connector-common = { git = "https://github.com/infinyon/fluvio", tag = "v0.17.3", features = ["derive"] }
 fluvio-future = { version = "0.7.2", default-features = false }