diff --git a/Cargo.lock b/Cargo.lock
index 07a9b7f..2ef225b 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -851,7 +851,16 @@ version = "0.110.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "305d51c180ebdc46ef61bc60c54ae6512db3bc9a05842a1f1e762e45977019ab"
 dependencies = [
- "cranelift-entity",
+ "cranelift-entity 0.110.2",
+]
+
+[[package]]
+name = "cranelift-bforest"
+version = "0.112.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7b765ed4349e66bedd9b88c7691da42e24c7f62067a6be17ddffa949367b6e17"
+dependencies = [
+ "cranelift-entity 0.112.2",
 ]
 
 [[package]]
@@ -864,6 +873,16 @@ dependencies = [
  "serde_derive",
 ]
 
+[[package]]
+name = "cranelift-bitset"
+version = "0.112.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9eaa2aece6237198afd32bff57699e08d4dccb8d3902c214fc1e6ba907247ca4"
+dependencies = [
+ "serde",
+ "serde_derive",
+]
+
 [[package]]
 name = "cranelift-codegen"
 version = "0.110.2"
@@ -871,18 +890,41 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "bd7ca95e831c18d1356da783765c344207cbdffea91e13e47fa9327dbb2e0719"
 dependencies = [
  "bumpalo",
- "cranelift-bforest",
- "cranelift-bitset",
- "cranelift-codegen-meta",
- "cranelift-codegen-shared",
- "cranelift-control",
- "cranelift-entity",
- "cranelift-isle",
+ "cranelift-bforest 0.110.2",
+ "cranelift-bitset 0.110.2",
+ "cranelift-codegen-meta 0.110.2",
+ "cranelift-codegen-shared 0.110.2",
+ "cranelift-control 0.110.2",
+ "cranelift-entity 0.110.2",
+ "cranelift-isle 0.110.2",
  "gimli 0.28.1",
  "hashbrown 0.14.5",
  "log",
- "regalloc2",
- "rustc-hash",
+ "regalloc2 0.9.3",
+ "rustc-hash 1.1.0",
+ "smallvec",
+ "target-lexicon",
+]
+
+[[package]]
+name = "cranelift-codegen"
+version = "0.112.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "351824439e59d42f0e4fa5aac1d13deded155120043565769e55cd4ad3ca8ed9"
+dependencies = [
+ "bumpalo",
+ "cranelift-bforest 0.112.2",
+ "cranelift-bitset 0.112.2",
+ "cranelift-codegen-meta 0.112.2",
+ "cranelift-codegen-shared 0.112.2",
+ "cranelift-control 0.112.2",
+ "cranelift-entity 0.112.2",
+ "cranelift-isle 0.112.2",
+ "gimli 0.29.0",
+ "hashbrown 0.14.5",
+ "log",
+ "regalloc2 0.10.2",
+ "rustc-hash 2.0.0",
  "smallvec",
  "target-lexicon",
 ]
@@ -893,7 +935,16 @@ version = "0.110.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "450c105fa1e51bfba4e95a86e926504a867ad5639d63f31d43fe3b7ec1f1c9ef"
 dependencies = [
- "cranelift-codegen-shared",
+ "cranelift-codegen-shared 0.110.2",
+]
+
+[[package]]
+name = "cranelift-codegen-meta"
+version = "0.112.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5a0ce0273d7a493ef8f31f606849a4e931c19187a4923f5f87fc1f2b13109981"
+dependencies = [
+ "cranelift-codegen-shared 0.112.2",
 ]
 
 [[package]]
@@ -902,6 +953,12 @@ version = "0.110.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "5479117cd1266881479908d383086561cee37e49affbea9b1e6b594cc21cc220"
 
+[[package]]
+name = "cranelift-codegen-shared"
+version = "0.112.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0f72016ac35579051913f4f07f6b36c509ed69412d852fd44c8e1d7b7fa6d92a"
+
 [[package]]
 name = "cranelift-control"
 version = "0.110.2"
@@ -911,13 +968,33 @@ dependencies = [
  "arbitrary",
 ]
 
+[[package]]
+name = "cranelift-control"
+version = "0.112.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "db28951d21512c4fd0554ef179bfb11e4eb6815062957a9173824eee5de0c46c"
+dependencies = [
+ "arbitrary",
+]
+
 [[package]]
 name = "cranelift-entity"
 version = "0.110.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "a48cb0a194c9ba82fec35a1e492055388d89b2e3c03dee9dcf2488892be8004d"
 dependencies = [
- "cranelift-bitset",
+ "cranelift-bitset 0.110.2",
+ "serde",
+ "serde_derive",
+]
+
+[[package]]
+name = "cranelift-entity"
+version = "0.112.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "14ebe592a2f81af9237cf9be29dd3854ecb72108cfffa59e85ef12389bf939e3"
+dependencies = [
+ "cranelift-bitset 0.112.2",
  "serde",
  "serde_derive",
 ]
@@ -928,7 +1005,19 @@ version = "0.110.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "8327afc6c1c05f4be62fefce5b439fa83521c65363a322e86ea32c85e7ceaf64"
 dependencies = [
- "cranelift-codegen",
+ "cranelift-codegen 0.110.2",
+ "log",
+ "smallvec",
+ "target-lexicon",
+]
+
+[[package]]
+name = "cranelift-frontend"
+version = "0.112.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "4437db9d60c7053ac91ded0802740c2ccf123ee6d6898dd906c34f8c530cd119"
+dependencies = [
+ "cranelift-codegen 0.112.2",
  "log",
  "smallvec",
  "target-lexicon",
@@ -940,13 +1029,30 @@ version = "0.110.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "56b08621c00321efcfa3eee6a3179adc009e21ea8d24ca7adc3c326184bc3f48"
 
+[[package]]
+name = "cranelift-isle"
+version = "0.112.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "230cb33572b9926e210f2ca28145f2bc87f389e1456560932168e2591feb65c1"
+
 [[package]]
 name = "cranelift-native"
 version = "0.110.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "d51180b147c8557c1196c77b098f04140c91962e135ea152cd2fcabf40cf365c"
 dependencies = [
- "cranelift-codegen",
+ "cranelift-codegen 0.110.2",
+ "libc",
+ "target-lexicon",
+]
+
+[[package]]
+name = "cranelift-native"
+version = "0.112.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "364524ac7aef7070b1141478724abebeec297d4ea1e87ad8b8986465e91146d9"
+dependencies = [
+ "cranelift-codegen 0.112.2",
  "libc",
  "target-lexicon",
 ]
@@ -957,14 +1063,30 @@ version = "0.110.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "019e3dccb7f15e0bc14f0ddc034ec608a66df8e05c9e1e16f75a7716f8461799"
 dependencies = [
- "cranelift-codegen",
- "cranelift-entity",
- "cranelift-frontend",
+ "cranelift-codegen 0.110.2",
+ "cranelift-entity 0.110.2",
+ "cranelift-frontend 0.110.2",
+ "itertools",
+ "log",
+ "smallvec",
+ "wasmparser 0.212.0",
+ "wasmtime-types 23.0.2",
+]
+
+[[package]]
+name = "cranelift-wasm"
+version = "0.112.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0572cbd9d136a62c0f39837b6bce3b0978b96b8586794042bec0c214668fd6f5"
+dependencies = [
+ "cranelift-codegen 0.112.2",
+ "cranelift-entity 0.112.2",
+ "cranelift-frontend 0.112.2",
  "itertools",
  "log",
  "smallvec",
- "wasmparser",
- "wasmtime-types",
+ "wasmparser 0.217.0",
+ "wasmtime-types 25.0.2",
 ]
 
 [[package]]
@@ -1409,7 +1531,7 @@ dependencies = [
  "fluvio-future",
  "fluvio-protocol 0.11.0 (git+https://github.com/infinyon/fluvio?tag=v0.11.12)",
  "fluvio-sc-schema",
- "fluvio-smartengine",
+ "fluvio-smartengine 0.8.1 (git+https://github.com/infinyon/fluvio?tag=v0.11.12)",
  "fluvio-smartmodule 0.7.4 (git+https://github.com/infinyon/fluvio?tag=v0.11.12)",
  "fluvio-socket",
  "fluvio-spu-schema",
@@ -1452,6 +1574,17 @@ dependencies = [
  "zstd",
 ]
 
+[[package]]
+name = "fluvio-compression"
+version = "0.3.4"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.12.0#bc5b4ea48ec9df454af0c83e78d2ef94a71c8f72"
+dependencies = [
+ "bytes",
+ "fluvio-types 0.5.1",
+ "serde",
+ "thiserror",
+]
+
 [[package]]
 name = "fluvio-connector-common"
 version = "0.0.0"
@@ -1464,7 +1597,7 @@ dependencies = [
  "fluvio-connector-package",
  "fluvio-future",
  "fluvio-sc-schema",
- "fluvio-smartengine",
+ "fluvio-smartengine 0.8.1 (git+https://github.com/infinyon/fluvio?tag=v0.11.12)",
  "futures",
  "futures-util",
  "serde",
@@ -1493,7 +1626,7 @@ dependencies = [
  "bytesize-serde",
  "fluvio-compression 0.3.3 (git+https://github.com/infinyon/fluvio?tag=v0.11.12)",
  "fluvio-controlplane-metadata",
- "fluvio-smartengine",
+ "fluvio-smartengine 0.8.1 (git+https://github.com/infinyon/fluvio?tag=v0.11.12)",
  "fluvio-types 0.5.0 (git+https://github.com/infinyon/fluvio?tag=v0.11.12)",
  "humantime-serde",
  "minijinja",
@@ -1597,6 +1730,26 @@ dependencies = [
  "tracing",
 ]
 
+[[package]]
+name = "fluvio-protocol"
+version = "0.11.0"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.12.0#bc5b4ea48ec9df454af0c83e78d2ef94a71c8f72"
+dependencies = [
+ "bytes",
+ "cfg-if 1.0.0",
+ "content_inspector",
+ "crc32c",
+ "eyre",
+ "fluvio-compression 0.3.4",
+ "fluvio-protocol-derive 0.5.4 (git+https://github.com/infinyon/fluvio?tag=v0.12.0)",
+ "fluvio-types 0.5.1",
+ "flv-util",
+ "once_cell",
+ "semver 1.0.23",
+ "thiserror",
+ "tracing",
+]
+
 [[package]]
 name = "fluvio-protocol-derive"
 version = "0.5.4"
@@ -1620,6 +1773,17 @@ dependencies = [
  "tracing",
 ]
 
+[[package]]
+name = "fluvio-protocol-derive"
+version = "0.5.4"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.12.0#bc5b4ea48ec9df454af0c83e78d2ef94a71c8f72"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 1.0.109",
+ "tracing",
+]
+
 [[package]]
 name = "fluvio-sc-schema"
 version = "0.24.3"
@@ -1653,8 +1817,26 @@ dependencies = [
  "serde_yaml",
  "thiserror",
  "tracing",
- "wasi-common",
- "wasmtime",
+ "wasi-common 23.0.2",
+ "wasmtime 23.0.2",
+]
+
+[[package]]
+name = "fluvio-smartengine"
+version = "0.8.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.12.0#bc5b4ea48ec9df454af0c83e78d2ef94a71c8f72"
+dependencies = [
+ "anyhow",
+ "cfg-if 1.0.0",
+ "derive_builder",
+ "fluvio-future",
+ "fluvio-protocol 0.11.0 (git+https://github.com/infinyon/fluvio?tag=v0.12.0)",
+ "fluvio-smartmodule 0.7.4 (git+https://github.com/infinyon/fluvio?tag=v0.12.0)",
+ "serde",
+ "thiserror",
+ "tracing",
+ "wasi-common 25.0.2",
+ "wasmtime 25.0.2",
 ]
 
 [[package]]
@@ -1682,6 +1864,18 @@ dependencies = [
  "tracing",
 ]
 
+[[package]]
+name = "fluvio-smartmodule"
+version = "0.7.4"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.12.0#bc5b4ea48ec9df454af0c83e78d2ef94a71c8f72"
+dependencies = [
+ "eyre",
+ "fluvio-protocol 0.11.0 (git+https://github.com/infinyon/fluvio?tag=v0.12.0)",
+ "fluvio-smartmodule-derive 0.6.3 (git+https://github.com/infinyon/fluvio?tag=v0.12.0)",
+ "thiserror",
+ "tracing",
+]
+
 [[package]]
 name = "fluvio-smartmodule-derive"
 version = "0.6.3"
@@ -1703,6 +1897,16 @@ dependencies = [
  "syn 2.0.72",
 ]
 
+[[package]]
+name = "fluvio-smartmodule-derive"
+version = "0.6.3"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.12.0#bc5b4ea48ec9df454af0c83e78d2ef94a71c8f72"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 2.0.72",
+]
+
 [[package]]
 name = "fluvio-socket"
 version = "0.14.10"
@@ -1806,6 +2010,17 @@ dependencies = [
  "tracing",
 ]
 
+[[package]]
+name = "fluvio-types"
+version = "0.5.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.12.0#bc5b4ea48ec9df454af0c83e78d2ef94a71c8f72"
+dependencies = [
+ "serde",
+ "thiserror",
+ "toml",
+ "tracing",
+]
+
 [[package]]
 name = "fluvio-wasm-timer"
 version = "0.2.5"
@@ -2069,6 +2284,11 @@ name = "gimli"
 version = "0.29.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "40ecd4077b5ae9fd2e9e169b102c6c330d0605168eb0e8bf79952b256dbefffd"
+dependencies = [
+ "fallible-iterator",
+ "indexmap",
+ "stable_deref_trait",
+]
 
 [[package]]
 name = "gloo-timers"
@@ -2237,7 +2457,7 @@ dependencies = [
  "encoding_rs",
  "fluvio",
  "fluvio-connector-common",
- "fluvio-smartengine",
+ "fluvio-smartengine 0.8.1 (git+https://github.com/infinyon/fluvio?tag=v0.12.0)",
  "futures",
  "http 1.1.0",
  "humantime",
@@ -3256,7 +3476,20 @@ checksum = "ad156d539c879b7a24a363a2016d77961786e71f48f2e2fc8302a92abd2429a6"
 dependencies = [
  "hashbrown 0.13.2",
  "log",
- "rustc-hash",
+ "rustc-hash 1.1.0",
+ "slice-group-by",
+ "smallvec",
+]
+
+[[package]]
+name = "regalloc2"
+version = "0.10.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "12908dbeb234370af84d0579b9f68258a0f67e201412dd9a2814e6f45b2fc0f0"
+dependencies = [
+ "hashbrown 0.14.5",
+ "log",
+ "rustc-hash 2.0.0",
  "slice-group-by",
  "smallvec",
 ]
@@ -3383,6 +3616,12 @@ version = "1.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "08d43f7aa6b08d49f382cde6a7982047c3426db949b1424bc4b7ec9ae12c6ce2"
 
+[[package]]
+name = "rustc-hash"
+version = "2.0.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "583034fd73374156e66797ed8e5b0d5690409c9226b22d87cb7f19821c05d152"
+
 [[package]]
 name = "rustc_version"
 version = "0.2.3"
@@ -4467,7 +4706,7 @@ version = "1.6.3"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "97fee6b57c6a41524a810daee9286c02d7752c4253064d0b05472833a438f675"
 dependencies = [
- "cfg-if 1.0.0",
+ "cfg-if 0.1.10",
  "static_assertions",
 ]
 
@@ -4664,8 +4903,34 @@ dependencies = [
  "system-interface",
  "thiserror",
  "tracing",
- "wasmtime",
- "wiggle",
+ "wasmtime 23.0.2",
+ "wiggle 23.0.2",
+ "windows-sys 0.52.0",
+]
+
+[[package]]
+name = "wasi-common"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5f1e63f999ecfdd96d64d35b39d0577318d9d2eae2d41603d4befda3b3dfe252"
+dependencies = [
+ "anyhow",
+ "bitflags 2.6.0",
+ "cap-fs-ext",
+ "cap-rand",
+ "cap-std",
+ "cap-time-ext",
+ "fs-set-times",
+ "io-extras",
+ "io-lifetimes 2.0.3",
+ "log",
+ "once_cell",
+ "rustix 0.38.34",
+ "system-interface",
+ "thiserror",
+ "tracing",
+ "wasmtime 25.0.2",
+ "wiggle 25.0.2",
  "windows-sys 0.52.0",
 ]
 
@@ -4748,13 +5013,23 @@ dependencies = [
 
 [[package]]
 name = "wasm-encoder"
-version = "0.215.0"
+version = "0.217.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "4fb56df3e06b8e6b77e37d2969a50ba51281029a9aeb3855e76b7f49b6418847"
+checksum = "7b88b0814c9a2b323a9b46c687e726996c255ac8b64aa237dd11c81ed4854760"
 dependencies = [
  "leb128",
 ]
 
+[[package]]
+name = "wasm-encoder"
+version = "0.219.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "29cbbd772edcb8e7d524a82ee8cef8dd046fc14033796a754c3ad246d019fa54"
+dependencies = [
+ "leb128",
+ "wasmparser 0.219.1",
+]
+
 [[package]]
 name = "wasm-streams"
 version = "0.4.0"
@@ -4782,6 +5057,30 @@ dependencies = [
  "serde",
 ]
 
+[[package]]
+name = "wasmparser"
+version = "0.217.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ca917a21307d3adf2b9857b94dd05ebf8496bdcff4437a9b9fb3899d3e6c74e7"
+dependencies = [
+ "ahash",
+ "bitflags 2.6.0",
+ "hashbrown 0.14.5",
+ "indexmap",
+ "semver 1.0.23",
+ "serde",
+]
+
+[[package]]
+name = "wasmparser"
+version = "0.219.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5c771866898879073c53b565a6c7b49953795159836714ac56a5befb581227c5"
+dependencies = [
+ "bitflags 2.6.0",
+ "indexmap",
+]
+
 [[package]]
 name = "wasmprinter"
 version = "0.212.0"
@@ -4790,7 +5089,18 @@ checksum = "dfac65326cc561112af88c3028f6dfdb140acff67ede33a8e86be2dc6b8956f7"
 dependencies = [
  "anyhow",
  "termcolor",
- "wasmparser",
+ "wasmparser 0.212.0",
+]
+
+[[package]]
+name = "wasmprinter"
+version = "0.217.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "50dc568b3e0d47e8f96ea547c90790cfa783f0205160c40de894a427114185ce"
+dependencies = [
+ "anyhow",
+ "termcolor",
+ "wasmparser 0.217.0",
 ]
 
 [[package]]
@@ -4832,19 +5142,75 @@ dependencies = [
  "sptr",
  "target-lexicon",
  "wasm-encoder 0.212.0",
- "wasmparser",
- "wasmtime-asm-macros",
- "wasmtime-cache",
- "wasmtime-component-macro",
- "wasmtime-component-util",
- "wasmtime-cranelift",
- "wasmtime-environ",
- "wasmtime-fiber",
- "wasmtime-jit-debug",
- "wasmtime-jit-icache-coherence",
- "wasmtime-slab",
- "wasmtime-versioned-export-macros",
- "wasmtime-winch",
+ "wasmparser 0.212.0",
+ "wasmtime-asm-macros 23.0.2",
+ "wasmtime-cache 23.0.2",
+ "wasmtime-component-macro 23.0.2",
+ "wasmtime-component-util 23.0.2",
+ "wasmtime-cranelift 23.0.2",
+ "wasmtime-environ 23.0.2",
+ "wasmtime-fiber 23.0.2",
+ "wasmtime-jit-debug 23.0.2",
+ "wasmtime-jit-icache-coherence 23.0.2",
+ "wasmtime-slab 23.0.2",
+ "wasmtime-versioned-export-macros 23.0.2",
+ "wasmtime-winch 23.0.2",
+ "wat",
+ "windows-sys 0.52.0",
+]
+
+[[package]]
+name = "wasmtime"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ef01f9cb9636ed42a7ec5a09d785c0643590199dc7372dc22c7e2ba7a31a97d4"
+dependencies = [
+ "addr2line 0.22.0",
+ "anyhow",
+ "async-trait",
+ "bitflags 2.6.0",
+ "bumpalo",
+ "cc",
+ "cfg-if 1.0.0",
+ "encoding_rs",
+ "fxprof-processed-profile",
+ "gimli 0.29.0",
+ "hashbrown 0.14.5",
+ "indexmap",
+ "ittapi",
+ "libc",
+ "libm",
+ "log",
+ "mach2",
+ "memfd",
+ "object",
+ "once_cell",
+ "paste",
+ "postcard",
+ "psm",
+ "rayon",
+ "rustix 0.38.34",
+ "semver 1.0.23",
+ "serde",
+ "serde_derive",
+ "serde_json",
+ "smallvec",
+ "sptr",
+ "target-lexicon",
+ "wasm-encoder 0.217.0",
+ "wasmparser 0.217.0",
+ "wasmtime-asm-macros 25.0.2",
+ "wasmtime-cache 25.0.2",
+ "wasmtime-component-macro 25.0.2",
+ "wasmtime-component-util 25.0.2",
+ "wasmtime-cranelift 25.0.2",
+ "wasmtime-environ 25.0.2",
+ "wasmtime-fiber 25.0.2",
+ "wasmtime-jit-debug 25.0.2",
+ "wasmtime-jit-icache-coherence 25.0.2",
+ "wasmtime-slab 25.0.2",
+ "wasmtime-versioned-export-macros 25.0.2",
+ "wasmtime-winch 25.0.2",
  "wat",
  "windows-sys 0.52.0",
 ]
@@ -4858,6 +5224,15 @@ dependencies = [
  "cfg-if 1.0.0",
 ]
 
+[[package]]
+name = "wasmtime-asm-macros"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ba5b20797419d6baf2296db2354f864e8bb3447cacca9d151ce7700ae08b4460"
+dependencies = [
+ "cfg-if 1.0.0",
+]
+
 [[package]]
 name = "wasmtime-cache"
 version = "23.0.2"
@@ -4878,6 +5253,26 @@ dependencies = [
  "zstd",
 ]
 
+[[package]]
+name = "wasmtime-cache"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "272d5939e989c5b54e3fa83ef420e4a6dba3995c3065626066428b2f73ad1e06"
+dependencies = [
+ "anyhow",
+ "base64 0.21.7",
+ "directories-next",
+ "log",
+ "postcard",
+ "rustix 0.38.34",
+ "serde",
+ "serde_derive",
+ "sha2 0.10.8",
+ "toml",
+ "windows-sys 0.52.0",
+ "zstd",
+]
+
 [[package]]
 name = "wasmtime-component-macro"
 version = "23.0.2"
@@ -4888,9 +5283,24 @@ dependencies = [
  "proc-macro2",
  "quote",
  "syn 2.0.72",
- "wasmtime-component-util",
- "wasmtime-wit-bindgen",
- "wit-parser",
+ "wasmtime-component-util 23.0.2",
+ "wasmtime-wit-bindgen 23.0.2",
+ "wit-parser 0.212.0",
+]
+
+[[package]]
+name = "wasmtime-component-macro"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "26593c4b18c76ca3c3fbdd813d6692256537b639b851d8a6fe827e3d6966fc01"
+dependencies = [
+ "anyhow",
+ "proc-macro2",
+ "quote",
+ "syn 2.0.72",
+ "wasmtime-component-util 25.0.2",
+ "wasmtime-wit-bindgen 25.0.2",
+ "wit-parser 0.217.0",
 ]
 
 [[package]]
@@ -4899,6 +5309,12 @@ version = "23.0.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "1da707969bc31a565da9b32d087eb2370c95c6f2087c5539a15f2e3b27e77203"
 
+[[package]]
+name = "wasmtime-component-util"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a2ed562fbb0cbed20a56c369c8de146c1de06a48c19e26ed9aa45f073514ee60"
+
 [[package]]
 name = "wasmtime-cranelift"
 version = "23.0.2"
@@ -4907,20 +5323,45 @@ checksum = "62cb6135ec46994299be711b78b03acaa9480de3715f827d450f0c947a84977c"
 dependencies = [
  "anyhow",
  "cfg-if 1.0.0",
- "cranelift-codegen",
- "cranelift-control",
- "cranelift-entity",
- "cranelift-frontend",
- "cranelift-native",
- "cranelift-wasm",
+ "cranelift-codegen 0.110.2",
+ "cranelift-control 0.110.2",
+ "cranelift-entity 0.110.2",
+ "cranelift-frontend 0.110.2",
+ "cranelift-native 0.110.2",
+ "cranelift-wasm 0.110.2",
  "gimli 0.28.1",
  "log",
  "object",
  "target-lexicon",
  "thiserror",
- "wasmparser",
- "wasmtime-environ",
- "wasmtime-versioned-export-macros",
+ "wasmparser 0.212.0",
+ "wasmtime-environ 23.0.2",
+ "wasmtime-versioned-export-macros 23.0.2",
+]
+
+[[package]]
+name = "wasmtime-cranelift"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f389b789cbcb53a8499131182135dea21d7d97ad77e7fb66830f69479ef0e68c"
+dependencies = [
+ "anyhow",
+ "cfg-if 1.0.0",
+ "cranelift-codegen 0.112.2",
+ "cranelift-control 0.112.2",
+ "cranelift-entity 0.112.2",
+ "cranelift-frontend 0.112.2",
+ "cranelift-native 0.112.2",
+ "cranelift-wasm 0.112.2",
+ "gimli 0.29.0",
+ "log",
+ "object",
+ "smallvec",
+ "target-lexicon",
+ "thiserror",
+ "wasmparser 0.217.0",
+ "wasmtime-environ 25.0.2",
+ "wasmtime-versioned-export-macros 25.0.2",
 ]
 
 [[package]]
@@ -4931,8 +5372,8 @@ checksum = "9bcaa3b42a0718e9123da7fb75e8e13fc95df7db2a7e32e2f2f4f0d3333b7d6f"
 dependencies = [
  "anyhow",
  "cpp_demangle",
- "cranelift-bitset",
- "cranelift-entity",
+ "cranelift-bitset 0.110.2",
+ "cranelift-entity 0.110.2",
  "gimli 0.28.1",
  "indexmap",
  "log",
@@ -4944,10 +5385,37 @@ dependencies = [
  "serde_derive",
  "target-lexicon",
  "wasm-encoder 0.212.0",
- "wasmparser",
- "wasmprinter",
- "wasmtime-component-util",
- "wasmtime-types",
+ "wasmparser 0.212.0",
+ "wasmprinter 0.212.0",
+ "wasmtime-component-util 23.0.2",
+ "wasmtime-types 23.0.2",
+]
+
+[[package]]
+name = "wasmtime-environ"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "84b72debe8899f19bedf66f7071310f06ef62de943a1369ba9b373613e77dd3d"
+dependencies = [
+ "anyhow",
+ "cpp_demangle",
+ "cranelift-bitset 0.112.2",
+ "cranelift-entity 0.112.2",
+ "gimli 0.29.0",
+ "indexmap",
+ "log",
+ "object",
+ "postcard",
+ "rustc-demangle",
+ "semver 1.0.23",
+ "serde",
+ "serde_derive",
+ "target-lexicon",
+ "wasm-encoder 0.217.0",
+ "wasmparser 0.217.0",
+ "wasmprinter 0.217.0",
+ "wasmtime-component-util 25.0.2",
+ "wasmtime-types 25.0.2",
 ]
 
 [[package]]
@@ -4960,8 +5428,23 @@ dependencies = [
  "cc",
  "cfg-if 1.0.0",
  "rustix 0.38.34",
- "wasmtime-asm-macros",
- "wasmtime-versioned-export-macros",
+ "wasmtime-asm-macros 23.0.2",
+ "wasmtime-versioned-export-macros 23.0.2",
+ "windows-sys 0.52.0",
+]
+
+[[package]]
+name = "wasmtime-fiber"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "92b8d4d504266ee598204f9e69cea8714499cc7c5aeddaa9b3f76aaace8b0680"
+dependencies = [
+ "anyhow",
+ "cc",
+ "cfg-if 1.0.0",
+ "rustix 0.38.34",
+ "wasmtime-asm-macros 25.0.2",
+ "wasmtime-versioned-export-macros 25.0.2",
  "windows-sys 0.52.0",
 ]
 
@@ -4974,7 +5457,19 @@ dependencies = [
  "object",
  "once_cell",
  "rustix 0.38.34",
- "wasmtime-versioned-export-macros",
+ "wasmtime-versioned-export-macros 23.0.2",
+]
+
+[[package]]
+name = "wasmtime-jit-debug"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "48ed7f0bbb9da3252c252b05fcd5fd42672db161e6276aa96e92059500247d8c"
+dependencies = [
+ "object",
+ "once_cell",
+ "rustix 0.38.34",
+ "wasmtime-versioned-export-macros 25.0.2",
 ]
 
 [[package]]
@@ -4989,12 +5484,30 @@ dependencies = [
  "windows-sys 0.52.0",
 ]
 
+[[package]]
+name = "wasmtime-jit-icache-coherence"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1d930bc1325bc0448be6a11754156d770f56f6c3a61f440e9567f36cd2ea3065"
+dependencies = [
+ "anyhow",
+ "cfg-if 1.0.0",
+ "libc",
+ "windows-sys 0.52.0",
+]
+
 [[package]]
 name = "wasmtime-slab"
 version = "23.0.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "42eb8f6515708ec67974998c3e644101db4186308985f5ef7c2ef324ff33c948"
 
+[[package]]
+name = "wasmtime-slab"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "055a181b8d03998511294faea14798df436503f14d7fd20edcf7370ec583e80a"
+
 [[package]]
 name = "wasmtime-types"
 version = "23.0.2"
@@ -5002,11 +5515,25 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "046873fb8fb3e9652f3fd76fe99c8c8129007695c3d73b2e307fdae40f6e324c"
 dependencies = [
  "anyhow",
- "cranelift-entity",
+ "cranelift-entity 0.110.2",
+ "serde",
+ "serde_derive",
+ "smallvec",
+ "wasmparser 0.212.0",
+]
+
+[[package]]
+name = "wasmtime-types"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "c8340d976673ac3fdacac781f2afdc4933920c1adc738c3409e825dab3955399"
+dependencies = [
+ "anyhow",
+ "cranelift-entity 0.112.2",
  "serde",
  "serde_derive",
  "smallvec",
- "wasmparser",
+ "wasmparser 0.217.0",
 ]
 
 [[package]]
@@ -5020,6 +5547,17 @@ dependencies = [
  "syn 2.0.72",
 ]
 
+[[package]]
+name = "wasmtime-versioned-export-macros"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a4b0c1f76891f778db9602ee3fbb4eb7e9a3f511847d1fb1b69eddbcea28303c"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 2.0.72",
+]
+
 [[package]]
 name = "wasmtime-winch"
 version = "23.0.2"
@@ -5027,14 +5565,31 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "b2ceddc47a49af10908a288fdfdc296ab3932062cab62a785e3705bbb3709c59"
 dependencies = [
  "anyhow",
- "cranelift-codegen",
+ "cranelift-codegen 0.110.2",
  "gimli 0.28.1",
  "object",
  "target-lexicon",
- "wasmparser",
- "wasmtime-cranelift",
- "wasmtime-environ",
- "winch-codegen",
+ "wasmparser 0.212.0",
+ "wasmtime-cranelift 23.0.2",
+ "wasmtime-environ 23.0.2",
+ "winch-codegen 0.21.2",
+]
+
+[[package]]
+name = "wasmtime-winch"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a702ff5eff3b37c11453ec8b54ec444bb9f2c689c7a7af382766c52df86b1e9b"
+dependencies = [
+ "anyhow",
+ "cranelift-codegen 0.112.2",
+ "gimli 0.29.0",
+ "object",
+ "target-lexicon",
+ "wasmparser 0.217.0",
+ "wasmtime-cranelift 25.0.2",
+ "wasmtime-environ 25.0.2",
+ "winch-codegen 0.23.2",
 ]
 
 [[package]]
@@ -5046,7 +5601,19 @@ dependencies = [
  "anyhow",
  "heck",
  "indexmap",
- "wit-parser",
+ "wit-parser 0.212.0",
+]
+
+[[package]]
+name = "wasmtime-wit-bindgen"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b2fca2cbb5bb390f65d4434c19bf8d9873dfc60f10802918ebcd6f819a38d703"
+dependencies = [
+ "anyhow",
+ "heck",
+ "indexmap",
+ "wit-parser 0.217.0",
 ]
 
 [[package]]
@@ -5060,24 +5627,24 @@ dependencies = [
 
 [[package]]
 name = "wast"
-version = "215.0.0"
+version = "219.0.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "1ff1d00d893593249e60720be04a7c1f42f1c4dc3806a2869f4e66ab61eb54cb"
+checksum = "4f79a9d9df79986a68689a6b40bcc8d5d40d807487b235bebc2ac69a242b54a1"
 dependencies = [
  "bumpalo",
  "leb128",
  "memchr",
  "unicode-width",
- "wasm-encoder 0.215.0",
+ "wasm-encoder 0.219.1",
 ]
 
 [[package]]
 name = "wat"
-version = "1.215.0"
+version = "1.219.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "670bf4d9c8cf76ae242d70ded47c546525b6dafaa6871f9bcb065344bf2b4e3d"
+checksum = "8bc3cf014fb336883a411cd662f987abf6a1d2a27f2f0008616a0070bbf6bd0d"
 dependencies = [
- "wast 215.0.0",
+ "wast 219.0.1",
 ]
 
 [[package]]
@@ -5110,8 +5677,23 @@ dependencies = [
  "bitflags 2.6.0",
  "thiserror",
  "tracing",
- "wasmtime",
- "wiggle-macro",
+ "wasmtime 23.0.2",
+ "wiggle-macro 23.0.2",
+]
+
+[[package]]
+name = "wiggle"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e4ebee2be6b561d1fe91b37e960c02baa94cdee29af863f5f26a0637f344f27a"
+dependencies = [
+ "anyhow",
+ "async-trait",
+ "bitflags 2.6.0",
+ "thiserror",
+ "tracing",
+ "wasmtime 25.0.2",
+ "wiggle-macro 25.0.2",
 ]
 
 [[package]]
@@ -5129,6 +5711,21 @@ dependencies = [
  "witx",
 ]
 
+[[package]]
+name = "wiggle-generate"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "97c4a32959189041ccb260e6dfa7fcf907e665166e755a6a681c32423c90e45f"
+dependencies = [
+ "anyhow",
+ "heck",
+ "proc-macro2",
+ "quote",
+ "shellexpand",
+ "syn 2.0.72",
+ "witx",
+]
+
 [[package]]
 name = "wiggle-macro"
 version = "23.0.2"
@@ -5138,7 +5735,19 @@ dependencies = [
  "proc-macro2",
  "quote",
  "syn 2.0.72",
- "wiggle-generate",
+ "wiggle-generate 23.0.2",
+]
+
+[[package]]
+name = "wiggle-macro"
+version = "25.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6e1c266e16c4b24a29e055ec651e27fce1389c886bb00fbe78b8924a253a439b"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 2.0.72",
+ "wiggle-generate 25.0.2",
 ]
 
 [[package]]
@@ -5179,14 +5788,31 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "2a41b67a37ea74e83c38ef495cc213aba73385236b1deee883dc869e835003b9"
 dependencies = [
  "anyhow",
- "cranelift-codegen",
+ "cranelift-codegen 0.110.2",
  "gimli 0.28.1",
- "regalloc2",
+ "regalloc2 0.9.3",
  "smallvec",
  "target-lexicon",
- "wasmparser",
- "wasmtime-cranelift",
- "wasmtime-environ",
+ "wasmparser 0.212.0",
+ "wasmtime-cranelift 23.0.2",
+ "wasmtime-environ 23.0.2",
+]
+
+[[package]]
+name = "winch-codegen"
+version = "0.23.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d716f7c87db8ea79f1dc69f7344354b6256451bccca422ac4c3e0d607d144532"
+dependencies = [
+ "anyhow",
+ "cranelift-codegen 0.112.2",
+ "gimli 0.29.0",
+ "regalloc2 0.10.2",
+ "smallvec",
+ "target-lexicon",
+ "wasmparser 0.217.0",
+ "wasmtime-cranelift 25.0.2",
+ "wasmtime-environ 25.0.2",
 ]
 
 [[package]]
@@ -5401,7 +6027,25 @@ dependencies = [
  "serde_derive",
  "serde_json",
  "unicode-xid",
- "wasmparser",
+ "wasmparser 0.212.0",
+]
+
+[[package]]
+name = "wit-parser"
+version = "0.217.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "fb893dcd6d370cfdf19a0d9adfcd403efb8e544e1a0ea3a8b81a21fe392eaa78"
+dependencies = [
+ "anyhow",
+ "id-arena",
+ "indexmap",
+ "log",
+ "semver 1.0.23",
+ "serde",
+ "serde_derive",
+ "serde_json",
+ "unicode-xid",
+ "wasmparser 0.217.0",
 ]
 
 [[package]]
diff --git a/crates/http-source/Cargo.toml b/crates/http-source/Cargo.toml
index b7cf61b..6a06353 100644
--- a/crates/http-source/Cargo.toml
+++ b/crates/http-source/Cargo.toml
@@ -30,4 +30,4 @@ http = "1.1"
 
 fluvio = { git = "https://github.com/infinyon/fluvio", tag = "v0.11.12" }
 fluvio-connector-common = { git = "https://github.com/infinyon/fluvio", tag = "v0.11.12", features = ["derive"] }
-fluvio-smartengine = { git = "https://github.com/infinyon/fluvio", tag = "v0.11.12", features = ["engine"] }
+fluvio-smartengine = { git = "https://github.com/infinyon/fluvio", tag = "v0.12.0", features = ["engine"] }