diff --git a/benchmark/Cargo.toml b/benchmark/Cargo.toml
index 7999c69..b57b5aa 100644
--- a/benchmark/Cargo.toml
+++ b/benchmark/Cargo.toml
@@ -14,7 +14,7 @@ rust-version = "1.60"
 anyhow = { version = "1" }
 async-std = { version = "1", features = ["attributes"], optional = true }
 env_logger = { version = "0.9" }
-flume = { version = "0.10", default-features = false, features = ["async"] }
+flume = { version = "0.11", default-features = false, features = ["async"] }
 clap = { version = "4.5", features = ["derive", "env"] }
 tokio = { version = "1.10", features = ["full"], optional = true }
 
diff --git a/examples/Cargo.toml b/examples/Cargo.toml
index 8ab61c9..46667d9 100644
--- a/examples/Cargo.toml
+++ b/examples/Cargo.toml
@@ -14,7 +14,7 @@ rust-version = "1.60"
 anyhow = { version = "1" }
 async-std = { version = "1", features = ["attributes"], optional = true }
 env_logger = { version = "0.9" }
-flume = { version = "0.10", default-features = false, features = ["async"] }
+flume = { version = "0.11", default-features = false, features = ["async"] }
 clap = { version = "4.5", features = ["derive", "env"] }
 tokio = { version = "1.10", features = ["full"], optional = true }
 
diff --git a/sea-streamer-file/Cargo.toml b/sea-streamer-file/Cargo.toml
index 86c3a25..02fa076 100644
--- a/sea-streamer-file/Cargo.toml
+++ b/sea-streamer-file/Cargo.toml
@@ -20,7 +20,7 @@ anyhow = { version = "1", optional = true }
 async-std = { version = "1", optional = true }
 env_logger = { version = "0.9", optional = true }
 fastrand = { version = "1" }
-flume = { version = "0.10", default-features = false, features = ["async"] }
+flume = { version = "0.11", default-features = false, features = ["async"] }
 lazy_static = { version = "1.4" }
 log = { version = "0.4", default-features = false }
 notify = { version = "6" }
diff --git a/sea-streamer-redis/Cargo.toml b/sea-streamer-redis/Cargo.toml
index 84e7749..a62e0ca 100644
--- a/sea-streamer-redis/Cargo.toml
+++ b/sea-streamer-redis/Cargo.toml
@@ -19,7 +19,7 @@ rustdoc-args = ["--cfg", "docsrs"]
 anyhow = { version = "1", optional = true }
 async-std = { version = "1", optional = true }
 env_logger = { version = "0.9", optional = true }
-flume = { version = "0.10", default-features = false, features = ["async"] }
+flume = { version = "0.11", default-features = false, features = ["async"] }
 lazy_static = { version = "1.4" }
 log = { version = "0.4", default-features = false }
 mac_address = { version = "1" }
diff --git a/sea-streamer-stdio/Cargo.toml b/sea-streamer-stdio/Cargo.toml
index a2509f5..212e50b 100644
--- a/sea-streamer-stdio/Cargo.toml
+++ b/sea-streamer-stdio/Cargo.toml
@@ -18,7 +18,7 @@ rustdoc-args = ["--cfg", "docsrs"]
 [dependencies]
 anyhow = { version = "1", optional = true }
 env_logger = { version = "0.9", optional = true }
-flume = { version = "0.10", default-features = false, features = ["async"] }
+flume = { version = "0.11", default-features = false, features = ["async"] }
 lazy_static = { version = "1.4" }
 log = { version = "0.4", default-features = false }
 nom = { version = "7" }