From 67c2655ae3469ed4e84e7f2ca786878e14d4d850 Mon Sep 17 00:00:00 2001
From: "dependabot[bot]" <49699333+dependabot[bot]@users.noreply.github.com>
Date: Mon, 14 Oct 2024 08:23:57 +0000
Subject: [PATCH] chore(deps): bump fluvio from v0.11.9 to v0.12.0

Bumps [fluvio](https://github.com/infinyon/fluvio) from v0.11.9 to v0.12.0.
- [Release notes](https://github.com/infinyon/fluvio/releases)
- [Changelog](https://github.com/infinyon/fluvio/blob/master/CHANGELOG.md)
- [Commits](https://github.com/infinyon/fluvio/compare/c93d7c33b0a4a48b30050a5faf5a4f4ee211aca1...bc5b4ea48ec9df454af0c83e78d2ef94a71c8f72)

---
updated-dependencies:
- dependency-name: fluvio
  dependency-type: direct:production
...

Signed-off-by: dependabot[bot] <support@github.com>
---
 Cargo.lock | 565 +++++++++++++++++++++++++++++++++++++++++++++++------
 Cargo.toml |   2 +-
 2 files changed, 503 insertions(+), 64 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index 87c023c..78c3be9 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -210,6 +210,17 @@ dependencies = [
  "futures-lite 1.13.0",
 ]
 
+[[package]]
+name = "async-net"
+version = "2.0.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b948000fad4873c1c9339d60f2623323a0cfd3816e5181033c6a5cb68b2accf7"
+dependencies = [
+ "async-io 2.3.3",
+ "blocking",
+ "futures-lite 2.3.0",
+]
+
 [[package]]
 name = "async-process"
 version = "1.8.1"
@@ -412,9 +423,9 @@ checksum = "1fd0f2584146f6f2ef48085050886acf353beff7305ebd1ae69500e27c67f64b"
 
 [[package]]
 name = "bytes"
-version = "1.6.0"
+version = "1.7.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "514de17de45fdb8dc022b1a7975556c53c86f9f0aa5f534b98977b171857c2c9"
+checksum = "428d9aa8fbc0670b7b8d6030a7fadd0f86151cae55e4dbbece15f3780a3dfaf3"
 
 [[package]]
 name = "bytesize"
@@ -535,6 +546,12 @@ version = "0.1.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "fd16c4719339c4530435d38e511904438d07cce7950afa3718a84ac36c10e89e"
 
+[[package]]
+name = "cfg_aliases"
+version = "0.2.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "613afe47fcd5fac7ccf1db93babcb082c5994d996f20b8b159f2ad1658eb5724"
+
 [[package]]
 name = "chrono"
 version = "0.4.38"
@@ -759,8 +776,18 @@ version = "0.14.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "7b750cb3417fd1b327431a470f388520309479ab0bf5e323505daf0290cd3850"
 dependencies = [
- "darling_core",
- "darling_macro",
+ "darling_core 0.14.4",
+ "darling_macro 0.14.4",
+]
+
+[[package]]
+name = "darling"
+version = "0.20.10"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6f63b86c8a8826a49b8c21f08a2d07338eec8d900540f8630dc76284be802989"
+dependencies = [
+ "darling_core 0.20.10",
+ "darling_macro 0.20.10",
 ]
 
 [[package]]
@@ -773,21 +800,46 @@ dependencies = [
  "ident_case",
  "proc-macro2",
  "quote",
- "strsim",
+ "strsim 0.10.0",
  "syn 1.0.109",
 ]
 
+[[package]]
+name = "darling_core"
+version = "0.20.10"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "95133861a8032aaea082871032f5815eb9e98cef03fa916ab4500513994df9e5"
+dependencies = [
+ "fnv",
+ "ident_case",
+ "proc-macro2",
+ "quote",
+ "strsim 0.11.1",
+ "syn 2.0.66",
+]
+
 [[package]]
 name = "darling_macro"
 version = "0.14.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "a4aab4dbc9f7611d8b55048a3a16d2d010c2c8334e46304b40ac1cc14bf3b48e"
 dependencies = [
- "darling_core",
+ "darling_core 0.14.4",
  "quote",
  "syn 1.0.109",
 ]
 
+[[package]]
+name = "darling_macro"
+version = "0.20.10"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d336a2a514f6ccccaa3e09b02d41d35330c07ddf03a62165fcec10bb561c7806"
+dependencies = [
+ "darling_core 0.20.10",
+ "quote",
+ "syn 2.0.66",
+]
+
 [[package]]
 name = "debugid"
 version = "0.8.0"
@@ -803,7 +855,16 @@ version = "0.12.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "8d67778784b508018359cbc8696edb3db78160bab2c2a28ba7f56ef6932997f8"
 dependencies = [
- "derive_builder_macro",
+ "derive_builder_macro 0.12.0",
+]
+
+[[package]]
+name = "derive_builder"
+version = "0.20.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "507dfb09ea8b7fa618fcf76e953f4f5e192547945816d5358edffe39f6f94947"
+dependencies = [
+ "derive_builder_macro 0.20.2",
 ]
 
 [[package]]
@@ -812,22 +873,44 @@ version = "0.12.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "c11bdc11a0c47bc7d37d582b5285da6849c96681023680b906673c5707af7b0f"
 dependencies = [
- "darling",
+ "darling 0.14.4",
  "proc-macro2",
  "quote",
  "syn 1.0.109",
 ]
 
+[[package]]
+name = "derive_builder_core"
+version = "0.20.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2d5bcf7b024d6835cfb3d473887cd966994907effbe9227e8c8219824d06c4e8"
+dependencies = [
+ "darling 0.20.10",
+ "proc-macro2",
+ "quote",
+ "syn 2.0.66",
+]
+
 [[package]]
 name = "derive_builder_macro"
 version = "0.12.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "ebcda35c7a396850a55ffeac740804b40ffec779b98fffbb1738f4033f0ee79e"
 dependencies = [
- "derive_builder_core",
+ "derive_builder_core 0.12.0",
  "syn 1.0.109",
 ]
 
+[[package]]
+name = "derive_builder_macro"
+version = "0.20.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ab63b0e2bf4d5928aff72e83a7dace85d7bba5fe12dcc3c5a572d78caffd3f3c"
+dependencies = [
+ "derive_builder_core 0.20.2",
+ "syn 2.0.66",
+]
+
 [[package]]
 name = "digest"
 version = "0.10.7"
@@ -906,12 +989,24 @@ version = "0.4.23"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "0f0042ff8246a363dbe77d2ceedb073339e85a804b9a47636c6e016a9a32c05f"
 dependencies = [
- "enum-ordinalize",
+ "enum-ordinalize 3.1.15",
  "proc-macro2",
  "quote",
  "syn 1.0.109",
 ]
 
+[[package]]
+name = "educe"
+version = "0.6.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1d7bc049e1bd8cdeb31b68bbd586a9464ecf9f3944af3958a7a9d0f8b9799417"
+dependencies = [
+ "enum-ordinalize 4.3.0",
+ "proc-macro2",
+ "quote",
+ "syn 2.0.66",
+]
+
 [[package]]
 name = "either"
 version = "1.12.0"
@@ -940,6 +1035,26 @@ dependencies = [
  "syn 2.0.66",
 ]
 
+[[package]]
+name = "enum-ordinalize"
+version = "4.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "fea0dcfa4e54eeb516fe454635a95753ddd39acda650ce703031c6973e315dd5"
+dependencies = [
+ "enum-ordinalize-derive",
+]
+
+[[package]]
+name = "enum-ordinalize-derive"
+version = "4.3.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0d28318a75d4aead5c4db25382e8ef717932d0346600cacae6357eb5941bc5ff"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 2.0.66",
+]
+
 [[package]]
 name = "equivalent"
 version = "1.0.1"
@@ -1060,18 +1175,18 @@ dependencies = [
  "bytes",
  "cfg-if",
  "chrono",
- "derive_builder",
+ "derive_builder 0.12.0",
  "dirs 5.0.1",
  "event-listener 3.1.0",
- "fluvio-compression",
- "fluvio-future",
- "fluvio-protocol",
- "fluvio-sc-schema",
+ "fluvio-compression 0.3.2",
+ "fluvio-future 0.6.2",
+ "fluvio-protocol 0.10.15",
+ "fluvio-sc-schema 0.24.0",
  "fluvio-smartengine",
- "fluvio-smartmodule",
- "fluvio-socket",
- "fluvio-spu-schema",
- "fluvio-types",
+ "fluvio-smartmodule 0.7.3",
+ "fluvio-socket 0.14.8",
+ "fluvio-spu-schema 0.14.7",
+ "fluvio-types 0.4.6",
  "futures-util",
  "once_cell",
  "pin-project",
@@ -1085,6 +1200,41 @@ dependencies = [
  "tracing",
 ]
 
+[[package]]
+name = "fluvio"
+version = "0.23.3"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.12.0#bc5b4ea48ec9df454af0c83e78d2ef94a71c8f72"
+dependencies = [
+ "anyhow",
+ "async-channel 1.9.0",
+ "async-lock 3.4.0",
+ "async-trait",
+ "cfg-if",
+ "chrono",
+ "derive_builder 0.20.2",
+ "dirs 5.0.1",
+ "event-listener 5.3.1",
+ "fluvio-compression 0.3.4",
+ "fluvio-future 0.7.0",
+ "fluvio-protocol 0.11.0",
+ "fluvio-sc-schema 0.24.3",
+ "fluvio-smartmodule 0.7.4",
+ "fluvio-socket 0.14.11",
+ "fluvio-spu-schema 0.16.0",
+ "fluvio-stream-dispatcher",
+ "fluvio-types 0.5.1",
+ "futures-util",
+ "once_cell",
+ "pin-project",
+ "semver",
+ "serde",
+ "siphasher",
+ "thiserror",
+ "tokio",
+ "toml 0.8.14",
+ "tracing",
+]
+
 [[package]]
 name = "fluvio-compression"
 version = "0.3.2"
@@ -1099,19 +1249,34 @@ dependencies = [
  "zstd 0.13.1",
 ]
 
+[[package]]
+name = "fluvio-compression"
+version = "0.3.4"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.12.0#bc5b4ea48ec9df454af0c83e78d2ef94a71c8f72"
+dependencies = [
+ "bytes",
+ "flate2",
+ "fluvio-types 0.5.1",
+ "lz4_flex",
+ "serde",
+ "snap",
+ "thiserror",
+ "zstd 0.13.1",
+]
+
 [[package]]
 name = "fluvio-connector-common"
 version = "0.0.0"
 source = "git+https://github.com/infinyon/fluvio?tag=v0.11.9#c93d7c33b0a4a48b30050a5faf5a4f4ee211aca1"
 dependencies = [
  "anyhow",
- "async-net",
+ "async-net 1.8.0",
  "async-trait",
- "fluvio",
+ "fluvio 0.22.3",
  "fluvio-connector-derive",
  "fluvio-connector-package",
- "fluvio-future",
- "fluvio-sc-schema",
+ "fluvio-future 0.6.2",
+ "fluvio-sc-schema 0.24.0",
  "fluvio-smartengine",
  "futures",
  "futures-util",
@@ -1139,10 +1304,10 @@ dependencies = [
  "anyhow",
  "bytesize",
  "bytesize-serde",
- "fluvio-compression",
- "fluvio-controlplane-metadata",
+ "fluvio-compression 0.3.2",
+ "fluvio-controlplane-metadata 0.28.2",
  "fluvio-smartengine",
- "fluvio-types",
+ "fluvio-types 0.4.6",
  "humantime-serde",
  "minijinja",
  "openapiv3",
@@ -1162,12 +1327,37 @@ dependencies = [
  "base64 0.22.1",
  "bytes",
  "bytesize",
- "derive_builder",
+ "derive_builder 0.12.0",
  "flate2",
- "fluvio-future",
- "fluvio-protocol",
- "fluvio-stream-model",
- "fluvio-types",
+ "fluvio-future 0.6.2",
+ "fluvio-protocol 0.10.15",
+ "fluvio-stream-model 0.11.2",
+ "fluvio-types 0.4.6",
+ "flv-util",
+ "humantime-serde",
+ "lenient_semver",
+ "semver",
+ "serde",
+ "serde_yaml",
+ "thiserror",
+ "toml 0.8.14",
+ "tracing",
+]
+
+[[package]]
+name = "fluvio-controlplane-metadata"
+version = "0.29.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.12.0#bc5b4ea48ec9df454af0c83e78d2ef94a71c8f72"
+dependencies = [
+ "anyhow",
+ "base64 0.22.1",
+ "bytes",
+ "bytesize",
+ "derive_builder 0.20.2",
+ "flate2",
+ "fluvio-protocol 0.11.0",
+ "fluvio-stream-model 0.11.4",
+ "fluvio-types 0.5.1",
  "flv-util",
  "humantime-serde",
  "lenient_semver",
@@ -1187,7 +1377,7 @@ checksum = "d7bb78c21409e7d24567b9b8a0d880e13ae5ef8fbbfb2a514c3966cd83e078c9"
 dependencies = [
  "anyhow",
  "async-io 1.13.0",
- "async-net",
+ "async-net 1.8.0",
  "async-std",
  "async-trait",
  "cfg-if",
@@ -1205,6 +1395,30 @@ dependencies = [
  "ws_stream_wasm",
 ]
 
+[[package]]
+name = "fluvio-future"
+version = "0.7.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0a28090046453db33a8bace0e1f71350b9878cd7fb576e48592ae8284bc83c7e"
+dependencies = [
+ "anyhow",
+ "async-io 2.3.3",
+ "async-net 2.0.0",
+ "async-std",
+ "async-trait",
+ "cfg-if",
+ "fluvio-wasm-timer",
+ "futures-lite 2.3.0",
+ "futures-util",
+ "openssl",
+ "openssl-sys",
+ "pin-project",
+ "socket2 0.5.7",
+ "thiserror",
+ "tracing",
+ "ws_stream_wasm",
+]
+
 [[package]]
 name = "fluvio-protocol"
 version = "0.10.15"
@@ -1214,10 +1428,32 @@ dependencies = [
  "content_inspector",
  "crc32c",
  "eyre",
- "fluvio-compression",
- "fluvio-future",
- "fluvio-protocol-derive",
- "fluvio-types",
+ "fluvio-compression 0.3.2",
+ "fluvio-future 0.6.2",
+ "fluvio-protocol-derive 0.5.4 (git+https://github.com/infinyon/fluvio?tag=v0.11.9)",
+ "fluvio-types 0.4.6",
+ "flv-util",
+ "once_cell",
+ "semver",
+ "thiserror",
+ "tokio-util",
+ "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",
+ "content_inspector",
+ "crc32c",
+ "eyre",
+ "fluvio-compression 0.3.4",
+ "fluvio-future 0.7.0",
+ "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",
@@ -1237,17 +1473,44 @@ 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.0"
 source = "git+https://github.com/infinyon/fluvio?tag=v0.11.9#c93d7c33b0a4a48b30050a5faf5a4f4ee211aca1"
 dependencies = [
  "anyhow",
- "fluvio-controlplane-metadata",
- "fluvio-protocol",
- "fluvio-socket",
- "fluvio-stream-model",
- "fluvio-types",
+ "fluvio-controlplane-metadata 0.28.2",
+ "fluvio-protocol 0.10.15",
+ "fluvio-socket 0.14.8",
+ "fluvio-stream-model 0.11.2",
+ "fluvio-types 0.4.6",
+ "paste",
+ "static_assertions",
+ "thiserror",
+ "tracing",
+]
+
+[[package]]
+name = "fluvio-sc-schema"
+version = "0.24.3"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.12.0#bc5b4ea48ec9df454af0c83e78d2ef94a71c8f72"
+dependencies = [
+ "anyhow",
+ "fluvio-controlplane-metadata 0.29.1",
+ "fluvio-protocol 0.11.0",
+ "fluvio-socket 0.14.11",
+ "fluvio-stream-model 0.11.4",
  "paste",
  "static_assertions",
  "thiserror",
@@ -1261,10 +1524,10 @@ source = "git+https://github.com/infinyon/fluvio?tag=v0.11.9#c93d7c33b0a4a48b300
 dependencies = [
  "anyhow",
  "cfg-if",
- "derive_builder",
- "fluvio-future",
- "fluvio-protocol",
- "fluvio-smartmodule",
+ "derive_builder 0.12.0",
+ "fluvio-future 0.6.2",
+ "fluvio-protocol 0.10.15",
+ "fluvio-smartmodule 0.7.3",
  "humantime-serde",
  "serde",
  "serde_json",
@@ -1281,8 +1544,20 @@ version = "0.7.3"
 source = "git+https://github.com/infinyon/fluvio?tag=v0.11.9#c93d7c33b0a4a48b30050a5faf5a4f4ee211aca1"
 dependencies = [
  "eyre",
- "fluvio-protocol",
- "fluvio-smartmodule-derive",
+ "fluvio-protocol 0.10.15",
+ "fluvio-smartmodule-derive 0.6.3 (git+https://github.com/infinyon/fluvio?tag=v0.11.9)",
+ "thiserror",
+ "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",
+ "fluvio-smartmodule-derive 0.6.3 (git+https://github.com/infinyon/fluvio?tag=v0.12.0)",
  "thiserror",
  "tracing",
 ]
@@ -1297,6 +1572,16 @@ dependencies = [
  "syn 2.0.66",
 ]
 
+[[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.66",
+]
+
 [[package]]
 name = "fluvio-socket"
 version = "0.14.8"
@@ -1309,10 +1594,35 @@ dependencies = [
  "bytes",
  "cfg-if",
  "event-listener 3.1.0",
- "fluvio-future",
- "fluvio-protocol",
+ "fluvio-future 0.6.2",
+ "fluvio-protocol 0.10.15",
+ "futures-util",
+ "nix 0.28.0",
+ "once_cell",
+ "pin-project",
+ "semver",
+ "thiserror",
+ "tokio",
+ "tokio-util",
+ "tracing",
+]
+
+[[package]]
+name = "fluvio-socket"
+version = "0.14.11"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.12.0#bc5b4ea48ec9df454af0c83e78d2ef94a71c8f72"
+dependencies = [
+ "async-channel 1.9.0",
+ "async-lock 3.4.0",
+ "async-trait",
+ "built",
+ "bytes",
+ "cfg-if",
+ "event-listener 5.3.1",
+ "fluvio-future 0.7.0",
+ "fluvio-protocol 0.11.0",
  "futures-util",
- "nix",
+ "nix 0.29.0",
  "once_cell",
  "pin-project",
  "semver",
@@ -1328,18 +1638,59 @@ version = "0.14.7"
 source = "git+https://github.com/infinyon/fluvio?tag=v0.11.9#c93d7c33b0a4a48b30050a5faf5a4f4ee211aca1"
 dependencies = [
  "bytes",
- "derive_builder",
- "educe",
+ "derive_builder 0.12.0",
+ "educe 0.4.23",
  "flate2",
- "fluvio-future",
- "fluvio-protocol",
- "fluvio-smartmodule",
- "fluvio-types",
+ "fluvio-future 0.6.2",
+ "fluvio-protocol 0.10.15",
+ "fluvio-smartmodule 0.7.3",
+ "fluvio-types 0.4.6",
  "serde",
  "static_assertions",
  "tracing",
 ]
 
+[[package]]
+name = "fluvio-spu-schema"
+version = "0.16.0"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.12.0#bc5b4ea48ec9df454af0c83e78d2ef94a71c8f72"
+dependencies = [
+ "bytes",
+ "derive_builder 0.20.2",
+ "educe 0.6.0",
+ "flate2",
+ "fluvio-future 0.7.0",
+ "fluvio-protocol 0.11.0",
+ "fluvio-smartmodule 0.7.4",
+ "fluvio-types 0.5.1",
+ "serde",
+ "static_assertions",
+ "tracing",
+]
+
+[[package]]
+name = "fluvio-stream-dispatcher"
+version = "0.13.5"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.12.0#bc5b4ea48ec9df454af0c83e78d2ef94a71c8f72"
+dependencies = [
+ "anyhow",
+ "async-channel 1.9.0",
+ "async-lock 3.4.0",
+ "async-trait",
+ "cfg-if",
+ "fluvio-future 0.7.0",
+ "fluvio-stream-model 0.11.4",
+ "fluvio-types 0.5.1",
+ "futures-util",
+ "once_cell",
+ "parking_lot 0.12.3",
+ "serde",
+ "serde_yaml",
+ "tempfile",
+ "tokio",
+ "tracing",
+]
+
 [[package]]
 name = "fluvio-stream-model"
 version = "0.11.2"
@@ -1353,6 +1704,19 @@ dependencies = [
  "tracing",
 ]
 
+[[package]]
+name = "fluvio-stream-model"
+version = "0.11.4"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.12.0#bc5b4ea48ec9df454af0c83e78d2ef94a71c8f72"
+dependencies = [
+ "async-lock 3.4.0",
+ "event-listener 5.3.1",
+ "k8-types",
+ "once_cell",
+ "serde",
+ "tracing",
+]
+
 [[package]]
 name = "fluvio-types"
 version = "0.4.6"
@@ -1365,6 +1729,18 @@ dependencies = [
  "tracing",
 ]
 
+[[package]]
+name = "fluvio-types"
+version = "0.5.1"
+source = "git+https://github.com/infinyon/fluvio?tag=v0.12.0#bc5b4ea48ec9df454af0c83e78d2ef94a71c8f72"
+dependencies = [
+ "event-listener 5.3.1",
+ "serde",
+ "thiserror",
+ "toml 0.8.14",
+ "tracing",
+]
+
 [[package]]
 name = "fluvio-wasm-timer"
 version = "0.2.5"
@@ -1373,7 +1749,7 @@ checksum = "b768c170dc045fa587a8f948c91f9bcfb87f774930477c6215addf54317f137f"
 dependencies = [
  "futures",
  "js-sys",
- "parking_lot",
+ "parking_lot 0.11.2",
  "pin-utils",
  "wasm-bindgen",
  "wasm-bindgen-futures",
@@ -1624,7 +2000,7 @@ dependencies = [
 name = "graphite-sink"
 version = "0.2.0"
 dependencies = [
- "fluvio",
+ "fluvio 0.23.3",
  "fluvio-connector-common",
  "futures",
  "serde",
@@ -1861,9 +2237,9 @@ dependencies = [
 
 [[package]]
 name = "k8-types"
-version = "0.8.5"
+version = "0.8.7"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "9f604a19941d3a538c86e8d2944b99cec1acd46043d9544804f2aaf0342a8401"
+checksum = "5b1996eb39fe3991c64d32262261d3a37a8a43fcf7bc3a5456ab399f02a50114"
 dependencies = [
  "serde",
  "serde_json",
@@ -2061,7 +2437,19 @@ checksum = "ab2156c4fce2f8df6c499cc1c763e4394b7482525bf2a9701c9d79d215f519e4"
 dependencies = [
  "bitflags 2.5.0",
  "cfg-if",
- "cfg_aliases",
+ "cfg_aliases 0.1.1",
+ "libc",
+]
+
+[[package]]
+name = "nix"
+version = "0.29.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "71e2746dc3a24dd78b3cfcb7be93368c6de9963d30f43a6a73998a9cf4b17b46"
+dependencies = [
+ "bitflags 2.5.0",
+ "cfg-if",
+ "cfg_aliases 0.2.1",
  "libc",
 ]
 
@@ -2225,7 +2613,17 @@ checksum = "7d17b78036a60663b797adeaee46f5c9dfebb86948d1255007a1d6be0271ff99"
 dependencies = [
  "instant",
  "lock_api",
- "parking_lot_core",
+ "parking_lot_core 0.8.6",
+]
+
+[[package]]
+name = "parking_lot"
+version = "0.12.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f1bf18183cf54e8d6059647fc3063646a1801cf30896933ec2311622cc4b9a27"
+dependencies = [
+ "lock_api",
+ "parking_lot_core 0.9.10",
 ]
 
 [[package]]
@@ -2237,11 +2635,24 @@ dependencies = [
  "cfg-if",
  "instant",
  "libc",
- "redox_syscall",
+ "redox_syscall 0.2.16",
  "smallvec",
  "winapi",
 ]
 
+[[package]]
+name = "parking_lot_core"
+version = "0.9.10"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1e401f977ab385c9e4e3ab30627d6f26d00e2c73eef317493c4ec6d468726cf8"
+dependencies = [
+ "cfg-if",
+ "libc",
+ "redox_syscall 0.5.7",
+ "smallvec",
+ "windows-targets 0.52.5",
+]
+
 [[package]]
 name = "paste"
 version = "1.0.15"
@@ -2436,6 +2847,15 @@ dependencies = [
  "bitflags 1.3.2",
 ]
 
+[[package]]
+name = "redox_syscall"
+version = "0.5.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9b6dfecf2c74bce2466cabf93f6664d6998a69eb21e39f4207930065b27b771f"
+dependencies = [
+ "bitflags 2.5.0",
+]
+
 [[package]]
 name = "redox_users"
 version = "0.4.5"
@@ -2749,6 +3169,12 @@ version = "0.10.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "73473c0e59e6d5812c5dfe2a064a6444949f089e20eec9a2e5506596494e4623"
 
+[[package]]
+name = "strsim"
+version = "0.11.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7da8b5736845d9f2fcb837ea5d9e2628564b3b043a70948a3f0b778838c5fb4f"
+
 [[package]]
 name = "syn"
 version = "1.0.109"
@@ -2793,6 +3219,19 @@ version = "0.12.14"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "e1fc403891a21bcfb7c37834ba66a547a8f402146eba7265b5a6d88059c9ff2f"
 
+[[package]]
+name = "tempfile"
+version = "3.11.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b8fcd239983515c23a32fb82099f97d0b11b8c72f654ed659363a95c3dad7a53"
+dependencies = [
+ "cfg-if",
+ "fastrand 2.1.0",
+ "once_cell",
+ "rustix 0.38.34",
+ "windows-sys 0.52.0",
+]
+
 [[package]]
 name = "thiserror"
 version = "1.0.61"
diff --git a/Cargo.toml b/Cargo.toml
index 92ab2fe..bc0b67e 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -10,5 +10,5 @@ serde = { version = "1.0", default-features = false, features = ["derive"]}
 futures = { version = "0.3", default-features = false }
 
 # Fluvio Dependencies
-fluvio = { git = "https://github.com/infinyon/fluvio", tag = "v0.11.9" }
+fluvio = { git = "https://github.com/infinyon/fluvio", tag = "v0.12.0" }
 fluvio-connector-common = { git = "https://github.com/infinyon/fluvio", tag = "v0.11.9", features = ["derive"]}