diff --git a/poetry.lock b/poetry.lock
index 9c15304a..c03c5e0c 100644
--- a/poetry.lock
+++ b/poetry.lock
@@ -15,7 +15,7 @@ files = [
 name = "aiohappyeyeballs"
 version = "2.3.5"
 description = "Happy Eyeballs for asyncio"
-optional = false
+optional = true
 python-versions = ">=3.8"
 files = [
     {file = "aiohappyeyeballs-2.3.5-py3-none-any.whl", hash = "sha256:4d6dea59215537dbc746e93e779caea8178c866856a721c9c660d7a5a7b8be03"},
@@ -26,7 +26,7 @@ files = [
 name = "aiohttp"
 version = "3.10.2"
 description = "Async http client/server framework (asyncio)"
-optional = false
+optional = true
 python-versions = ">=3.8"
 files = [
     {file = "aiohttp-3.10.2-cp310-cp310-macosx_10_9_universal2.whl", hash = "sha256:95213b3d79c7e387144e9cb7b9d2809092d6ff2c044cb59033aedc612f38fb6d"},
@@ -188,7 +188,7 @@ zstd = ["cramjam"]
 name = "aiosignal"
 version = "1.3.1"
 description = "aiosignal: a list of registered asynchronous callbacks"
-optional = false
+optional = true
 python-versions = ">=3.7"
 files = [
     {file = "aiosignal-1.3.1-py3-none-any.whl", hash = "sha256:f8376fb07dd1e86a584e4fcdec80b36b7f81aac666ebc724e2c090300dd83b17"},
@@ -252,7 +252,7 @@ test = ["coverage", "mypy", "pexpect", "ruff", "wheel"]
 name = "async-timeout"
 version = "4.0.3"
 description = "Timeout context manager for asyncio programs"
-optional = false
+optional = true
 python-versions = ">=3.7"
 files = [
     {file = "async-timeout-4.0.3.tar.gz", hash = "sha256:4640d96be84d82d02ed59ea2b7105a0f7b33abe8703703cd0ab0bf87c427522f"},
@@ -263,7 +263,7 @@ files = [
 name = "attrs"
 version = "23.2.0"
 description = "Classes Without Boilerplate"
-optional = false
+optional = true
 python-versions = ">=3.7"
 files = [
     {file = "attrs-23.2.0-py3-none-any.whl", hash = "sha256:99b87a485a5820b23b879f04c2305b44b951b502fd64be915879d77a7e8fc6f1"},
@@ -735,30 +735,30 @@ zstandard = ["zstandard"]
 
 [[package]]
 name = "faust-streaming"
-version = "0.11.1"
+version = "0.11.2"
 description = "Python Stream Processing. A Faust fork"
 optional = true
 python-versions = ">=3.8.0"
 files = [
-    {file = "faust-streaming-0.11.1.tar.gz", hash = "sha256:0b8b08e5388dc9fd4ecdb72cc8a51a9b996b60291777fb52183f65f2ed9962c4"},
-    {file = "faust_streaming-0.11.1-cp310-cp310-macosx_10_9_x86_64.whl", hash = "sha256:0d71380688510988392e544211f012bfe45d8c33afd04b1e05622502bbd25757"},
-    {file = "faust_streaming-0.11.1-cp310-cp310-macosx_11_0_arm64.whl", hash = "sha256:ab3bc2832040b9c4af46e4ee81d1a754fda96467a4de17c50e156bc53d7284a6"},
-    {file = "faust_streaming-0.11.1-cp310-cp310-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:548429c07bdc3390519f28dfcc8acbe71822e46e4b8c02b6e20762b4d918dd43"},
-    {file = "faust_streaming-0.11.1-cp311-cp311-macosx_10_9_x86_64.whl", hash = "sha256:913f03c53ea876125503fa8d21954edcce65f9ec1dce79565bde1a17d873f998"},
-    {file = "faust_streaming-0.11.1-cp311-cp311-macosx_11_0_arm64.whl", hash = "sha256:5fb92f2e9bf166234029feaffeae66b098b4d257c923df00eccbca55d2ba3059"},
-    {file = "faust_streaming-0.11.1-cp311-cp311-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:74ce646e9288f8aecd824d98113c472801b04c4e52207445aa0a25bc05d5b455"},
-    {file = "faust_streaming-0.11.1-cp38-cp38-macosx_10_9_x86_64.whl", hash = "sha256:74a4dc34c179ff002c7c2a05a48718fff40fa326d1700df98fd0f3ea85aba8b5"},
-    {file = "faust_streaming-0.11.1-cp38-cp38-macosx_11_0_arm64.whl", hash = "sha256:47740457b2e3be0bfea2ccd3589b1acd899dd1fef99fd7f93493605a87bab96a"},
-    {file = "faust_streaming-0.11.1-cp38-cp38-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:89acd63bcd9ba43a962d220ea19581d758141045ce31a5dc81b6d9681534c5ff"},
-    {file = "faust_streaming-0.11.1-cp39-cp39-macosx_10_9_x86_64.whl", hash = "sha256:a1164d96e68bca16a1d3510356cb05e9c6ac604fe5bfae4cbb6cbe85ff55e728"},
-    {file = "faust_streaming-0.11.1-cp39-cp39-macosx_11_0_arm64.whl", hash = "sha256:bc3560c7d8215486d075ee4f461214f9634e519ceebe30b0f7d49d9270bc9713"},
-    {file = "faust_streaming-0.11.1-cp39-cp39-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:53034f7bb9ebd4b4feefa96fe8227be5f6f2c0b1fc10eec6029005bad6398fdb"},
+    {file = "faust-streaming-0.11.2.tar.gz", hash = "sha256:b5ad07033ef91a31c271ae2b854034e40701b11e135dcb5136d3eae66330e017"},
+    {file = "faust_streaming-0.11.2-cp310-cp310-macosx_10_9_x86_64.whl", hash = "sha256:3e6414ddd489c0dbc847b5384735aec0ce3ec972a4a7b037e8683ae321fcfd0b"},
+    {file = "faust_streaming-0.11.2-cp310-cp310-macosx_11_0_arm64.whl", hash = "sha256:f6cd7240091273bcec4a7f2ade86c44f85703375cf5bae13f10a23a7342326c4"},
+    {file = "faust_streaming-0.11.2-cp310-cp310-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:516b2bb71391aa7861f455f4a86c9c65b9283d67cd2311fbc51bf0ed6f2410b0"},
+    {file = "faust_streaming-0.11.2-cp311-cp311-macosx_10_9_x86_64.whl", hash = "sha256:2d7ca4be1f4c2bc041f9372a5cd81e8e093f13af7e01dc4640a4c81360bbe17d"},
+    {file = "faust_streaming-0.11.2-cp311-cp311-macosx_11_0_arm64.whl", hash = "sha256:6e66a7c0302c0d946dc8b60cf660efd5eb8ec3774e8185f0dd18ea8e260e9c5d"},
+    {file = "faust_streaming-0.11.2-cp311-cp311-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:e7815721b912cf50aeee495702341439608f850e6e06a79111ce6d83b151ae53"},
+    {file = "faust_streaming-0.11.2-cp38-cp38-macosx_10_9_x86_64.whl", hash = "sha256:d5eaea086f99cfda4aa6f91ef1ec3fe38af77beb266e787d0215b1e779ece90a"},
+    {file = "faust_streaming-0.11.2-cp38-cp38-macosx_11_0_arm64.whl", hash = "sha256:07edd4861cb63915a19e0ba9174b748449437ff6b4f440b3eb56aabec9d07e3f"},
+    {file = "faust_streaming-0.11.2-cp38-cp38-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:0e1125dd2bab37b8600f22753ac9dacd046247fcc7eae25e49ecc57e9dfafe93"},
+    {file = "faust_streaming-0.11.2-cp39-cp39-macosx_10_9_x86_64.whl", hash = "sha256:d08f444a700e4989624ba98a077f112f27cb02aff8b04a36b423c373d099c61c"},
+    {file = "faust_streaming-0.11.2-cp39-cp39-macosx_11_0_arm64.whl", hash = "sha256:e65f0d3df8c090e024625ba52fafd668da76dc3186b9e68d8315e69e3d62f543"},
+    {file = "faust_streaming-0.11.2-cp39-cp39-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:133ac68be8034663fdef71eca0198cef2e60550240f576d6e67a96c60fbf22fb"},
 ]
 
 [package.dependencies]
 aiohttp = ">=3.8.0,<4.0"
 aiohttp-cors = ">=0.7,<2.0"
-aiokafka = ">=0.9.0"
+aiokafka = ">=0.10.0"
 click = ">=6.7,<8.2"
 croniter = ">=0.3.16"
 intervaltree = "*"
@@ -795,7 +795,7 @@ yaml = ["pyyaml (>=5.1)"]
 name = "frozenlist"
 version = "1.4.1"
 description = "A list-like structure which implements collections.abc.MutableSequence"
-optional = false
+optional = true
 python-versions = ">=3.8"
 files = [
     {file = "frozenlist-1.4.1-cp310-cp310-macosx_10_9_universal2.whl", hash = "sha256:f9aa1878d1083b276b0196f2dfbe00c9b7e752475ed3b682025ff20c1c1f51ac"},
@@ -1362,7 +1362,7 @@ uvloop = ["uvloop (>=0.19.0)"]
 name = "multidict"
 version = "6.0.5"
 description = "multidict implementation"
-optional = false
+optional = true
 python-versions = ">=3.7"
 files = [
     {file = "multidict-6.0.5-cp310-cp310-macosx_10_9_universal2.whl", hash = "sha256:228b644ae063c10e7f324ab1ab6b548bdf6f8b47f3ec234fef1093bc2735e5f9"},
@@ -2350,7 +2350,7 @@ files = [
 name = "yarl"
 version = "1.9.4"
 description = "Yet another URL library"
-optional = false
+optional = true
 python-versions = ">=3.7"
 files = [
     {file = "yarl-1.9.4-cp310-cp310-macosx_10_9_universal2.whl", hash = "sha256:a8c1df72eb746f4136fe9a2e72b0c9dc1da1cbd23b5372f94b5820ff8ae30e0e"},