From f3f248c5bd4e4e4f863ddf000431bf8b32bd4f98 Mon Sep 17 00:00:00 2001
From: morenol <morenol@users.noreply.github.com>
Date: Tue, 2 May 2023 22:23:55 +0000
Subject: [PATCH] updates for new release (#32)

---
 Cargo.lock     | 237 ++++++++++++++++++++++++++-----------------------
 Cargo.toml     |   4 +-
 Connector.toml |   2 +-
 README.md      |   6 +-
 4 files changed, 133 insertions(+), 116 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index 6d5fcb5..af9b342 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -37,6 +37,12 @@ dependencies = [
  "memchr",
 ]
 
+[[package]]
+name = "aho-corasick"
+version = "1.0.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "67fc08ce920c31afb70f013dcce1bfc3a3195de6a228474e45e1f145b36f8d04"
+
 [[package]]
 name = "android_system_properties"
 version = "0.1.5"
@@ -359,6 +365,16 @@ version = "1.2.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "38fcc2979eff34a4b84e1cf9a1e3da42a7d44b3b690a40cdcb23e3d556cfb2e5"
 
+[[package]]
+name = "bytesize-serde"
+version = "0.2.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "86d1eb2fd2668859e9785b99700c66b7ea9fdeda35d99f95827a4e5493440178"
+dependencies = [
+ "bytesize",
+ "serde",
+]
+
 [[package]]
 name = "cargo-lock"
 version = "8.0.3"
@@ -465,18 +481,18 @@ dependencies = [
 
 [[package]]
 name = "cranelift-bforest"
-version = "0.94.0"
+version = "0.95.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "862eb053fc21f991db27c73bc51494fe77aadfa09ea257cb43b62a2656fd4cc1"
+checksum = "1277fbfa94bc82c8ec4af2ded3e639d49ca5f7f3c7eeab2c66accd135ece4e70"
 dependencies = [
  "cranelift-entity",
 ]
 
 [[package]]
 name = "cranelift-codegen"
-version = "0.94.0"
+version = "0.95.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "038a74bc85da2f6f9e237c51b7998b47229c0f9da69b4c6b0590cf6621c45d46"
+checksum = "c6e8c31ad3b2270e9aeec38723888fe1b0ace3bea2b06b3f749ccf46661d3220"
 dependencies = [
  "bumpalo",
  "cranelift-bforest",
@@ -494,33 +510,33 @@ dependencies = [
 
 [[package]]
 name = "cranelift-codegen-meta"
-version = "0.94.0"
+version = "0.95.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "c7fb720a7955cf7cc92c58f3896952589062e6f12d8eb35ef4337e708ed2e738"
+checksum = "c8ac5ac30d62b2d66f12651f6b606dbdfd9c2cfd0908de6b387560a277c5c9da"
 dependencies = [
  "cranelift-codegen-shared",
 ]
 
 [[package]]
 name = "cranelift-codegen-shared"
-version = "0.94.0"
+version = "0.95.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "c0954f9426cf0fa7ad57910ea5822a09c5da590222a767a6c38080a8534a0af8"
+checksum = "dd82b8b376247834b59ed9bdc0ddeb50f517452827d4a11bccf5937b213748b8"
 
 [[package]]
 name = "cranelift-entity"
-version = "0.94.0"
+version = "0.95.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "68c7096c1a66cfa73899645f0a46a6f5c91641e678eeafb0fc47a19ab34069ca"
+checksum = "40099d38061b37e505e63f89bab52199037a72b931ad4868d9089ff7268660b0"
 dependencies = [
  "serde",
 ]
 
 [[package]]
 name = "cranelift-frontend"
-version = "0.94.0"
+version = "0.95.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "697f2fdaceb228fea413ea91baa7c6b8533fc2e61ac5a08db7acc1b31e673a2a"
+checksum = "64a25d9d0a0ae3079c463c34115ec59507b4707175454f0eee0891e83e30e82d"
 dependencies = [
  "cranelift-codegen",
  "log",
@@ -530,15 +546,15 @@ dependencies = [
 
 [[package]]
 name = "cranelift-isle"
-version = "0.94.0"
+version = "0.95.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f41037f4863e0c6716dbe60e551d501f4197383cb43d75038c0170159fc8fb5b"
+checksum = "80de6a7d0486e4acbd5f9f87ec49912bf4c8fb6aea00087b989685460d4469ba"
 
 [[package]]
 name = "cranelift-native"
-version = "0.94.0"
+version = "0.95.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "797c6e5643eb654bb7bf496f1f03518323a89b937b84020b786620f910364a52"
+checksum = "bb6b03e0e03801c4b3fd8ce0758a94750c07a44e7944cc0ffbf0d3f2e7c79b00"
 dependencies = [
  "cranelift-codegen",
  "libc",
@@ -547,9 +563,9 @@ dependencies = [
 
 [[package]]
 name = "cranelift-wasm"
-version = "0.94.0"
+version = "0.95.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "69b5fae12cefda3a2c43837e562dd525ab1d75b27989eece66de5b2c8fe120f9"
+checksum = "ff3220489a3d928ad91e59dd7aeaa8b3de18afb554a6211213673a71c90737ac"
 dependencies = [
  "cranelift-codegen",
  "cranelift-entity",
@@ -944,8 +960,8 @@ dependencies = [
 
 [[package]]
 name = "fluvio"
-version = "0.18.1"
-source = "git+https://github.com/infinyon/fluvio?tag=v0.10.7#2c393a98216d55d848d7014a2d7d894940e549cd"
+version = "0.18.2"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.10.8-dev-3#a18b27255701ce5cf83cf30433c856d606f69838"
 dependencies = [
  "anyhow",
  "async-channel",
@@ -970,7 +986,7 @@ dependencies = [
  "fluvio-types",
  "futures-util",
  "once_cell",
- "pin-project-lite",
+ "pin-project",
  "semver",
  "serde",
  "serde_json",
@@ -983,8 +999,8 @@ dependencies = [
 
 [[package]]
 name = "fluvio-compression"
-version = "0.2.4"
-source = "git+https://github.com/infinyon/fluvio?tag=v0.10.7#2c393a98216d55d848d7014a2d7d894940e549cd"
+version = "0.2.5"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.10.8-dev-3#a18b27255701ce5cf83cf30433c856d606f69838"
 dependencies = [
  "bytes",
  "flate2",
@@ -997,7 +1013,7 @@ dependencies = [
 [[package]]
 name = "fluvio-connector-common"
 version = "0.0.0"
-source = "git+https://github.com/infinyon/fluvio?tag=v0.10.7#2c393a98216d55d848d7014a2d7d894940e549cd"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.10.8-dev-3#a18b27255701ce5cf83cf30433c856d606f69838"
 dependencies = [
  "anyhow",
  "async-net",
@@ -1012,14 +1028,14 @@ dependencies = [
  "futures-util",
  "serde",
  "serde_json",
- "serde_yaml 0.8.26",
+ "serde_yaml",
  "tracing",
 ]
 
 [[package]]
 name = "fluvio-connector-derive"
 version = "0.0.0"
-source = "git+https://github.com/infinyon/fluvio?tag=v0.10.7#2c393a98216d55d848d7014a2d7d894940e549cd"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.10.8-dev-3#a18b27255701ce5cf83cf30433c856d606f69838"
 dependencies = [
  "proc-macro2",
  "quote",
@@ -1029,27 +1045,29 @@ dependencies = [
 [[package]]
 name = "fluvio-connector-package"
 version = "0.0.0"
-source = "git+https://github.com/infinyon/fluvio?tag=v0.10.7#2c393a98216d55d848d7014a2d7d894940e549cd"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.10.8-dev-3#a18b27255701ce5cf83cf30433c856d606f69838"
 dependencies = [
  "anyhow",
  "bytesize",
+ "bytesize-serde",
  "fluvio-compression",
  "fluvio-controlplane-metadata",
  "fluvio-smartengine",
  "fluvio-types",
  "humantime-serde",
+ "minijinja",
  "once_cell",
  "openapiv3",
  "serde",
- "serde_yaml 0.8.26",
+ "serde_yaml",
  "toml 0.7.3",
  "tracing",
 ]
 
 [[package]]
 name = "fluvio-controlplane-metadata"
-version = "0.22.0"
-source = "git+https://github.com/infinyon/fluvio?tag=v0.10.7#2c393a98216d55d848d7014a2d7d894940e549cd"
+version = "0.22.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.10.8-dev-3#a18b27255701ce5cf83cf30433c856d606f69838"
 dependencies = [
  "async-trait",
  "base64 0.21.0",
@@ -1070,9 +1088,9 @@ dependencies = [
 
 [[package]]
 name = "fluvio-future"
-version = "0.4.5"
+version = "0.5.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "37174044230084d1cfd7c02f194c5ec127bb8bc17c76f0cd74e943f2fe86ec34"
+checksum = "a5f2d572470f98b25383ffe78d9c3fba2b986d9891efd78808025397e54eb1ec"
 dependencies = [
  "async-io",
  "async-net",
@@ -1094,8 +1112,8 @@ dependencies = [
 
 [[package]]
 name = "fluvio-protocol"
-version = "0.9.1"
-source = "git+https://github.com/infinyon/fluvio?tag=v0.10.7#2c393a98216d55d848d7014a2d7d894940e549cd"
+version = "0.9.2"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.10.8-dev-3#a18b27255701ce5cf83cf30433c856d606f69838"
 dependencies = [
  "bytes",
  "content_inspector",
@@ -1116,7 +1134,7 @@ dependencies = [
 [[package]]
 name = "fluvio-protocol-derive"
 version = "0.5.0"
-source = "git+https://github.com/infinyon/fluvio?tag=v0.10.7#2c393a98216d55d848d7014a2d7d894940e549cd"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.10.8-dev-3#a18b27255701ce5cf83cf30433c856d606f69838"
 dependencies = [
  "proc-macro2",
  "quote",
@@ -1126,14 +1144,14 @@ dependencies = [
 
 [[package]]
 name = "fluvio-sc-schema"
-version = "0.18.0"
-source = "git+https://github.com/infinyon/fluvio?tag=v0.10.7#2c393a98216d55d848d7014a2d7d894940e549cd"
+version = "0.18.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.10.8-dev-3#a18b27255701ce5cf83cf30433c856d606f69838"
 dependencies = [
+ "anyhow",
  "fluvio-controlplane-metadata",
  "fluvio-protocol",
  "fluvio-socket",
  "fluvio-types",
- "log",
  "paste",
  "static_assertions",
  "thiserror",
@@ -1142,8 +1160,8 @@ dependencies = [
 
 [[package]]
 name = "fluvio-smartengine"
-version = "0.7.2"
-source = "git+https://github.com/infinyon/fluvio?tag=v0.10.7#2c393a98216d55d848d7014a2d7d894940e549cd"
+version = "0.7.3"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.10.8-dev-3#a18b27255701ce5cf83cf30433c856d606f69838"
 dependencies = [
  "anyhow",
  "cfg-if",
@@ -1153,7 +1171,7 @@ dependencies = [
  "fluvio-smartmodule",
  "serde",
  "serde_json",
- "serde_yaml 0.9.21",
+ "serde_yaml",
  "thiserror",
  "tracing",
  "wasmtime",
@@ -1161,8 +1179,8 @@ dependencies = [
 
 [[package]]
 name = "fluvio-smartmodule"
-version = "0.5.0"
-source = "git+https://github.com/infinyon/fluvio?tag=v0.10.7#2c393a98216d55d848d7014a2d7d894940e549cd"
+version = "0.5.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.10.8-dev-3#a18b27255701ce5cf83cf30433c856d606f69838"
 dependencies = [
  "eyre",
  "fluvio-protocol",
@@ -1174,7 +1192,7 @@ dependencies = [
 [[package]]
 name = "fluvio-smartmodule-derive"
 version = "0.4.0"
-source = "git+https://github.com/infinyon/fluvio?tag=v0.10.7#2c393a98216d55d848d7014a2d7d894940e549cd"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.10.8-dev-3#a18b27255701ce5cf83cf30433c856d606f69838"
 dependencies = [
  "proc-macro2",
  "quote",
@@ -1183,8 +1201,8 @@ dependencies = [
 
 [[package]]
 name = "fluvio-socket"
-version = "0.14.0"
-source = "git+https://github.com/infinyon/fluvio?tag=v0.10.7#2c393a98216d55d848d7014a2d7d894940e549cd"
+version = "0.14.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.10.8-dev-3#a18b27255701ce5cf83cf30433c856d606f69838"
 dependencies = [
  "async-channel",
  "async-lock",
@@ -1207,8 +1225,8 @@ dependencies = [
 
 [[package]]
 name = "fluvio-spu-schema"
-version = "0.13.1"
-source = "git+https://github.com/infinyon/fluvio?tag=v0.10.7#2c393a98216d55d848d7014a2d7d894940e549cd"
+version = "0.13.2"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.10.8-dev-3#a18b27255701ce5cf83cf30433c856d606f69838"
 dependencies = [
  "bytes",
  "educe",
@@ -1217,7 +1235,6 @@ dependencies = [
  "fluvio-protocol",
  "fluvio-smartmodule",
  "fluvio-types",
- "log",
  "serde",
  "static_assertions",
  "tracing",
@@ -1225,8 +1242,8 @@ dependencies = [
 
 [[package]]
 name = "fluvio-stream-model"
-version = "0.9.0"
-source = "git+https://github.com/infinyon/fluvio?tag=v0.10.7#2c393a98216d55d848d7014a2d7d894940e549cd"
+version = "0.9.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.10.8-dev-3#a18b27255701ce5cf83cf30433c856d606f69838"
 dependencies = [
  "async-rwlock",
  "event-listener",
@@ -1236,8 +1253,8 @@ dependencies = [
 
 [[package]]
 name = "fluvio-types"
-version = "0.4.1"
-source = "git+https://github.com/infinyon/fluvio?tag=v0.10.7#2c393a98216d55d848d7014a2d7d894940e549cd"
+version = "0.4.2"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.10.8-dev-3#a18b27255701ce5cf83cf30433c856d606f69838"
 dependencies = [
  "event-listener",
  "thiserror",
@@ -1743,12 +1760,6 @@ dependencies = [
  "cc",
 ]
 
-[[package]]
-name = "linked-hash-map"
-version = "0.5.6"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "0717cef1bc8b636c6e1c1bbdefc09e6322da8a9321966e8928ef80d20f7f770f"
-
 [[package]]
 name = "linux-raw-sys"
 version = "0.1.4"
@@ -1832,6 +1843,15 @@ dependencies = [
  "autocfg",
 ]
 
+[[package]]
+name = "minijinja"
+version = "0.32.1"
+source = "git+https://github.com/mitsuhiko/minijinja?rev=c4b48dc5be9de0143e06bef97618c7ed029fb155#c4b48dc5be9de0143e06bef97618c7ed029fb155"
+dependencies = [
+ "aho-corasick 1.0.1",
+ "serde",
+]
+
 [[package]]
 name = "miniz_oxide"
 version = "0.6.2"
@@ -2273,7 +2293,7 @@ version = "1.7.3"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "8b1f693b24f6ac912f4893ef08244d70b6067480d2f1a46e950c9691e6749d1d"
 dependencies = [
- "aho-corasick",
+ "aho-corasick 0.7.20",
  "memchr",
  "regex-syntax",
 ]
@@ -2522,18 +2542,6 @@ dependencies = [
  "serde",
 ]
 
-[[package]]
-name = "serde_yaml"
-version = "0.8.26"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "578a7433b776b56a35785ed5ce9a7e777ac0598aac5a6dd1b4b18a307c7fc71b"
-dependencies = [
- "indexmap",
- "ryu",
- "serde",
- "yaml-rust",
-]
-
 [[package]]
 name = "serde_yaml"
 version = "0.9.21"
@@ -3168,9 +3176,9 @@ dependencies = [
 
 [[package]]
 name = "wasmparser"
-version = "0.100.0"
+version = "0.102.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "64b20236ab624147dfbb62cf12a19aaf66af0e41b8398838b66e997d07d269d4"
+checksum = "48134de3d7598219ab9eaf6b91b15d8e50d31da76b8519fe4ecfcec2cf35104b"
 dependencies = [
  "indexmap",
  "url",
@@ -3178,9 +3186,9 @@ dependencies = [
 
 [[package]]
 name = "wasmtime"
-version = "7.0.0"
+version = "8.0.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "d137f87df6e037b2bcb960c2db7ea174e04fb897051380c14b5e5475a870669e"
+checksum = "f907fdead3153cb9bfb7a93bbd5b62629472dc06dee83605358c64c52ed3dda9"
 dependencies = [
  "anyhow",
  "async-trait",
@@ -3210,18 +3218,18 @@ dependencies = [
 
 [[package]]
 name = "wasmtime-asm-macros"
-version = "7.0.0"
+version = "8.0.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "ad63d4175d6af44af2046186c87deae4e9a8150b92de2d4809c6f745d5ee9b38"
+checksum = "d3b9daa7c14cd4fa3edbf69de994408d5f4b7b0959ac13fa69d465f6597f810d"
 dependencies = [
  "cfg-if",
 ]
 
 [[package]]
 name = "wasmtime-cache"
-version = "7.0.0"
+version = "8.0.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f3055fb327f795b4639f47b9dadad9d3d9b185fd3001adf8db08f5fa06d07032"
+checksum = "c86437fa68626fe896e5afc69234bb2b5894949083586535f200385adfd71213"
 dependencies = [
  "anyhow",
  "base64 0.21.0",
@@ -3239,9 +3247,9 @@ dependencies = [
 
 [[package]]
 name = "wasmtime-component-macro"
-version = "7.0.0"
+version = "8.0.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "64cf4906f990d6ab3065d042cf5a15eb7a2a5406d1c001a45ab9615de876458a"
+checksum = "267096ed7cc93b4ab15d3daa4f195e04dbb7e71c7e5c6457ae7d52e9dd9c3607"
 dependencies = [
  "anyhow",
  "proc-macro2",
@@ -3254,15 +3262,15 @@ dependencies = [
 
 [[package]]
 name = "wasmtime-component-util"
-version = "7.0.0"
+version = "8.0.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "22ccf49c18c1ce3f682310e642dcdc00ffc67f1ce0767c89a16fc8fcf5eaeb97"
+checksum = "74e02ca7a4a3c69d72b88f26f0192e333958df6892415ac9ab84dcc42c9000c2"
 
 [[package]]
 name = "wasmtime-cranelift"
-version = "7.0.0"
+version = "8.0.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "274590ecbb1179d45a5c8d9f54b9d236e9414d9ca3b861cd8956cec085508eb0"
+checksum = "b1cefde0cce8cb700b1b21b6298a3837dba46521affd7b8c38a9ee2c869eee04"
 dependencies = [
  "anyhow",
  "cranelift-codegen",
@@ -3276,14 +3284,30 @@ dependencies = [
  "target-lexicon",
  "thiserror",
  "wasmparser",
+ "wasmtime-cranelift-shared",
+ "wasmtime-environ",
+]
+
+[[package]]
+name = "wasmtime-cranelift-shared"
+version = "8.0.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "cd041e382ef5aea1b9fc78442394f1a4f6d676ce457e7076ca4cb3f397882f8b"
+dependencies = [
+ "anyhow",
+ "cranelift-codegen",
+ "cranelift-native",
+ "gimli",
+ "object",
+ "target-lexicon",
  "wasmtime-environ",
 ]
 
 [[package]]
 name = "wasmtime-environ"
-version = "7.0.0"
+version = "8.0.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "05b4a897e6ce1f2567ba98e7b1948c0e12cae1202fd88e7639f901b8ce9203f7"
+checksum = "a990198cee4197423045235bf89d3359e69bd2ea031005f4c2d901125955c949"
 dependencies = [
  "anyhow",
  "cranelift-entity",
@@ -3300,9 +3324,9 @@ dependencies = [
 
 [[package]]
 name = "wasmtime-fiber"
-version = "7.0.0"
+version = "8.0.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "01b1192624694399f601de28db78975ed20fa859da8e048bf8250bd3b38d302b"
+checksum = "7ab182d5ab6273a133ab88db94d8ca86dc3e57e43d70baaa4d98f94ddbd7d10a"
 dependencies = [
  "cc",
  "cfg-if",
@@ -3313,9 +3337,9 @@ dependencies = [
 
 [[package]]
 name = "wasmtime-jit"
-version = "7.0.0"
+version = "8.0.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f3f035bfe27ce5129c9d081d6288480f2e6ae9d16d0eb035a5d9e3b5b6c36658"
+checksum = "0de48df552cfca1c9b750002d3e07b45772dd033b0b206d5c0968496abf31244"
 dependencies = [
  "addr2line",
  "anyhow",
@@ -3338,9 +3362,9 @@ dependencies = [
 
 [[package]]
 name = "wasmtime-jit-debug"
-version = "7.0.0"
+version = "8.0.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "17e35d335dd2461c631ba24d2326d993bd3a4bdb4b0217e5bda4f518ba0e29f3"
+checksum = "6e0554b84c15a27d76281d06838aed94e13a77d7bf604bbbaf548aa20eb93846"
 dependencies = [
  "object",
  "once_cell",
@@ -3349,9 +3373,9 @@ dependencies = [
 
 [[package]]
 name = "wasmtime-jit-icache-coherence"
-version = "7.0.0"
+version = "8.0.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "4c8c01a070f55343f7afd309a9609c12378548b26c3f53c599bc711bb1ce42ee"
+checksum = "aecae978b13f7f67efb23bd827373ace4578f2137ec110bbf6a4a7cde4121bbd"
 dependencies = [
  "cfg-if",
  "libc",
@@ -3360,9 +3384,9 @@ dependencies = [
 
 [[package]]
 name = "wasmtime-runtime"
-version = "7.0.0"
+version = "8.0.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "1ac02cc14c8247f6e4e48c7653a79c226babac8f2cacdd933d3f15ca2a6ab20b"
+checksum = "658cf6f325232b6760e202e5255d823da5e348fdea827eff0a2a22319000b441"
 dependencies = [
  "anyhow",
  "cc",
@@ -3385,9 +3409,9 @@ dependencies = [
 
 [[package]]
 name = "wasmtime-types"
-version = "7.0.0"
+version = "8.0.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "c8dc0062ab053e1aa22d2355a2de4df482a0007fecae82ea02cc596c2329971d"
+checksum = "a4f6fffd2a1011887d57f07654dd112791e872e3ff4a2e626aee8059ee17f06f"
 dependencies = [
  "cranelift-entity",
  "serde",
@@ -3397,9 +3421,9 @@ dependencies = [
 
 [[package]]
 name = "wasmtime-wit-bindgen"
-version = "7.0.0"
+version = "8.0.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "fd2cf93f3c8a6f443d8a9098fddc5fd887783c0fe725dc10c54ca9280546421d"
+checksum = "983db9cc294d1adaa892a53ff6a0dc6605fc0ab1a4da5d8a2d2d4bde871ff7dd"
 dependencies = [
  "anyhow",
  "heck",
@@ -3697,15 +3721,6 @@ dependencies = [
  "web-sys",
 ]
 
-[[package]]
-name = "yaml-rust"
-version = "0.4.5"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "56c1936c4cc7a1c9ab21a1ebb602eb942ba868cbd44a99cb7cdc5892335e1c85"
-dependencies = [
- "linked-hash-map",
-]
-
 [[package]]
 name = "zstd"
 version = "0.11.2+zstd.1.5.2"
diff --git a/Cargo.toml b/Cargo.toml
index c7aceb2..848b430 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -21,8 +21,8 @@ rumqttc = { version = "0.20", features = ["url", "websocket"] }
 rustls = { version = "0.20" }
 rustls-native-certs = { version = "0.6" }
 
-fluvio = { git = "https://github.com/infinyon/fluvio", tag = "v0.10.7" }
-fluvio-connector-common = { git = "https://github.com/infinyon/fluvio", tag = "v0.10.7", features = ["derive"]}
+fluvio = { git = "https://github.com/infinyon/fluvio", tag = "v0.10.8-dev-3" }
+fluvio-connector-common = { git = "https://github.com/infinyon/fluvio", tag = "v0.10.8-dev-3", features = ["derive"]}
 
 
 [profile.release-lto]
diff --git a/Connector.toml b/Connector.toml
index a97db2b..4c6df73 100644
--- a/Connector.toml
+++ b/Connector.toml
@@ -2,7 +2,7 @@
 name = "mqtt-source"
 group = "infinyon"
 version = "0.2.0"
-apiVersion = "0.6.0"
+apiVersion = "0.1.0"
 fluvio = "0.10.8"
 description = "MQTT source connector"
 license = "Apache-2.0"
diff --git a/README.md b/README.md
index 309007e..e7e95a5 100644
--- a/README.md
+++ b/README.md
@@ -48,8 +48,9 @@ This is an example of connector config file:
 
 ```yaml
 # config-example.yaml
+apiVersion: 0.1.0
 meta:
-  version: 0.1.1
+  version: 0.2.0
   name: my-mqtt-connector
   type: mqtt-source
   topic: mqtt-topic
@@ -103,8 +104,9 @@ Fluvio MQTT Source Connector supports [Transformations](https://www.fluvio.io/do
 The previous example can be extended to add extra transformations to outgoing records:
 ```yaml
 # config-example.yaml
+apiVersion: 0.1.0
 meta:
-  version: 0.1.1
+  version: 0.2.0
   name: my-mqtt-connector
   type: mqtt-source
   topic: mqtt-topic