diff --git a/poetry.lock b/poetry.lock
index 2cdbb972f7..d9c1b6766a 100644
--- a/poetry.lock
+++ b/poetry.lock
@@ -1,4 +1,4 @@
-# This file is automatically @generated by Poetry 1.8.3 and should not be changed by hand.
+# This file is automatically @generated by Poetry 1.8.5 and should not be changed by hand.
 
 [[package]]
 name = "aiostream"
@@ -378,59 +378,60 @@ files = [
 
 [[package]]
 name = "confluent-kafka"
-version = "2.6.0"
+version = "2.6.2"
 description = "Confluent's Python client for Apache Kafka"
 optional = false
-python-versions = "*"
+python-versions = ">=3.7"
 files = [
-    {file = "confluent-kafka-2.6.0.tar.gz", hash = "sha256:f7afe69639bd2ab15404dd46a76e06213342a23cb5642d873342847cb2198c87"},
-    {file = "confluent_kafka-2.6.0-cp310-cp310-macosx_10_9_x86_64.whl", hash = "sha256:123d8cff9e1f45be333b266a49beb649bc1f8f9a67a37a8b35cf7f441cb03452"},
-    {file = "confluent_kafka-2.6.0-cp310-cp310-macosx_11_0_arm64.whl", hash = "sha256:ac6e397ee25019aeab320e5d4d3650078eb644908dc23eb2353726fe0c980dc8"},
-    {file = "confluent_kafka-2.6.0-cp310-cp310-manylinux_2_28_aarch64.whl", hash = "sha256:fd70c7ac03606c6bccbc92d1876586c5c81b80416d11e24af1e6d965edf43b92"},
-    {file = "confluent_kafka-2.6.0-cp310-cp310-manylinux_2_28_x86_64.whl", hash = "sha256:b9c8ea8e8817512a0431f2d95060cf1f88c20262a4f395816ee2c96fba1576bf"},
-    {file = "confluent_kafka-2.6.0-cp310-cp310-win_amd64.whl", hash = "sha256:ce5d55a3ed1ec8ff449592b1295208d5b3846f1962d1c3a8cfd0022ea3e01cf5"},
-    {file = "confluent_kafka-2.6.0-cp311-cp311-macosx_10_9_x86_64.whl", hash = "sha256:b6343f83052c6a6234a9c12cfa764a8b7440dbe0d293027606e314827fa7ad6a"},
-    {file = "confluent_kafka-2.6.0-cp311-cp311-macosx_11_0_arm64.whl", hash = "sha256:1a26e91200bbd0f09effe4d2f3b524c959c4a8925b62cb022676aeb223195f96"},
-    {file = "confluent_kafka-2.6.0-cp311-cp311-manylinux_2_28_aarch64.whl", hash = "sha256:6830b17a7c2253b95b873b3cf0fe877ce882e348cfcf9d4d939ade5626f87b1d"},
-    {file = "confluent_kafka-2.6.0-cp311-cp311-manylinux_2_28_x86_64.whl", hash = "sha256:7a9a58472e23112043e9a36e048241bccc3fd211f066fba778c070f0eafa35c8"},
-    {file = "confluent_kafka-2.6.0-cp311-cp311-win_amd64.whl", hash = "sha256:c134c1afdc6c83c82228a3bec9550a62748ec4cd9b6913efed4f4e903db321cc"},
-    {file = "confluent_kafka-2.6.0-cp312-cp312-macosx_10_9_x86_64.whl", hash = "sha256:7d14f70ca8c8435116119cf343028aa98987badb7ef06f1a37b480074b15ba64"},
-    {file = "confluent_kafka-2.6.0-cp312-cp312-macosx_11_0_arm64.whl", hash = "sha256:6c7d7161d6e68ffc7497e4768c30654151319edb6637739ac64e857a404fe531"},
-    {file = "confluent_kafka-2.6.0-cp312-cp312-manylinux_2_28_aarch64.whl", hash = "sha256:7189a64a0a829f391e65167de39234904ab374a6d453f6017f9287adb45cd469"},
-    {file = "confluent_kafka-2.6.0-cp312-cp312-manylinux_2_28_x86_64.whl", hash = "sha256:2a685e1c14b5cb20a8567cb42b762021488fce95c770cf6b1d3a4f175d9aaaac"},
-    {file = "confluent_kafka-2.6.0-cp312-cp312-win_amd64.whl", hash = "sha256:e9e4b279852b1c3f6457ee00245327cfe6023b3271b01e5ae73d3995cb7dfee4"},
-    {file = "confluent_kafka-2.6.0-cp313-cp313-macosx_13_0_arm64.whl", hash = "sha256:d17a8014a153c719d1b8a742c285a98aa96f482a78f09ebc0aedc593ae8bea29"},
-    {file = "confluent_kafka-2.6.0-cp313-cp313-macosx_13_0_x86_64.whl", hash = "sha256:ab6607603806dc05f3671a249c7bed3821321b58af151f9bc1b3cfd73bb526d8"},
-    {file = "confluent_kafka-2.6.0-cp313-cp313-manylinux_2_28_aarch64.whl", hash = "sha256:e46fbc61d36752b4a6d6c48e042dd2e10c7c2c4f00e51033fd8e3d435a2ee44c"},
-    {file = "confluent_kafka-2.6.0-cp313-cp313-manylinux_2_28_x86_64.whl", hash = "sha256:e36d8b924ed884e0eabbdb22519c059b528953358c739e0f6c0510e447260402"},
-    {file = "confluent_kafka-2.6.0-cp313-cp313-win_amd64.whl", hash = "sha256:47b9f8497938c75036f3dd124da50cb56599ae7c238803bfe2a52ed5b6cda197"},
-    {file = "confluent_kafka-2.6.0-cp36-cp36m-macosx_10_9_x86_64.whl", hash = "sha256:b6a67672eb7fb7669539e3c57ce3d51beefaf74f21498be92b8624ee86ab9d64"},
-    {file = "confluent_kafka-2.6.0-cp36-cp36m-manylinux_2_28_aarch64.whl", hash = "sha256:adbc37516440246edd3ff99069c49338cd27d6957d596075a19d6ff0bcb2fd40"},
-    {file = "confluent_kafka-2.6.0-cp36-cp36m-manylinux_2_28_x86_64.whl", hash = "sha256:4ee544a258891dddc709ae8f97242861f3eedd9e945688b5bfe99238004f68ee"},
-    {file = "confluent_kafka-2.6.0-cp36-cp36m-win_amd64.whl", hash = "sha256:e8c1fec7f05f52f2cd57969bacba7afc81c71cd4b2a6629ebba0df08d5c4068f"},
-    {file = "confluent_kafka-2.6.0-cp37-cp37m-macosx_10_9_x86_64.whl", hash = "sha256:4a7f244d0476e8c54bb1fe008195e2b9c491317976008945b0e4d3deef369310"},
-    {file = "confluent_kafka-2.6.0-cp37-cp37m-manylinux_2_28_aarch64.whl", hash = "sha256:86f7ef75cc977a0750db46b397a75db88a70879c2e8f4c1e0ed2b47e485a8110"},
-    {file = "confluent_kafka-2.6.0-cp37-cp37m-manylinux_2_28_x86_64.whl", hash = "sha256:045f67a6718e2e7312c6407f4510cd6c8293533936b9e6c4ebc78e46c4b4c5dd"},
-    {file = "confluent_kafka-2.6.0-cp37-cp37m-win_amd64.whl", hash = "sha256:4397365bf0d988a0bc21b82d717eba4fb879682d3d1737b88717c9cd6248a9c1"},
-    {file = "confluent_kafka-2.6.0-cp38-cp38-macosx_10_9_x86_64.whl", hash = "sha256:c486a4ebb998545a32e8abb70995db519c46913b3fbcaf022ca49a53ba807907"},
-    {file = "confluent_kafka-2.6.0-cp38-cp38-macosx_11_0_arm64.whl", hash = "sha256:1cdb0e2c755bfe8e85d7e1dbd949557646279a97c2a1925fdeff4054a509e07b"},
-    {file = "confluent_kafka-2.6.0-cp38-cp38-manylinux_2_28_aarch64.whl", hash = "sha256:c0dbbbefa0f2d0390bf86567d7d3711c4bf186def8f61b6ed9cff493af10e056"},
-    {file = "confluent_kafka-2.6.0-cp38-cp38-manylinux_2_28_x86_64.whl", hash = "sha256:bf44a28a1e5e53da1acb0d356ef6c96a23062c20ab6d0c4e470f50b29004e26b"},
-    {file = "confluent_kafka-2.6.0-cp38-cp38-win_amd64.whl", hash = "sha256:5ac22691e84eac632011d138d33c2d3446a6cb3db893bf42143737e461603554"},
-    {file = "confluent_kafka-2.6.0-cp39-cp39-macosx_10_9_x86_64.whl", hash = "sha256:87f022be528cb601d5a6b828328e7df795999fac3975ead82e8a3d2210d8b0f7"},
-    {file = "confluent_kafka-2.6.0-cp39-cp39-macosx_11_0_arm64.whl", hash = "sha256:e3b6756436a1302d19a1cb75623e23182fa197c853c87d43f15c99b43f8fbb17"},
-    {file = "confluent_kafka-2.6.0-cp39-cp39-manylinux_2_28_aarch64.whl", hash = "sha256:e05514ab6b50ed209d091029af868950ae5a2e46f9b27231d6d352352b7f3323"},
-    {file = "confluent_kafka-2.6.0-cp39-cp39-manylinux_2_28_x86_64.whl", hash = "sha256:bf59fb1054544de9ebcdf564c2acfad7d05cd758b91d82d6057a87529be898c8"},
-    {file = "confluent_kafka-2.6.0-cp39-cp39-win_amd64.whl", hash = "sha256:99a39a6a697ed1ab1d738835dfd18fb2f1ffd76fc2d00e037d4fa26a07cf798e"},
+    {file = "confluent_kafka-2.6.2-cp310-cp310-macosx_10_9_x86_64.whl", hash = "sha256:7879ee77d1ddc4123918a11e73931f8dc24959f897c09ba9003cd225c23ddfaf"},
+    {file = "confluent_kafka-2.6.2-cp310-cp310-macosx_11_0_arm64.whl", hash = "sha256:b7cf7dad9668ec1ec0f4cb794a237226ed4341871d78a8db6905f76009630f1c"},
+    {file = "confluent_kafka-2.6.2-cp310-cp310-manylinux_2_28_aarch64.whl", hash = "sha256:2d20715cb953bacee7182d162b9477f31e74cfda6817b9652d2f297037c7ba4c"},
+    {file = "confluent_kafka-2.6.2-cp310-cp310-manylinux_2_28_x86_64.whl", hash = "sha256:3128087d9783b27237946b712e2d797d569bd09071bf8e288947df7952fd79ee"},
+    {file = "confluent_kafka-2.6.2-cp310-cp310-win_amd64.whl", hash = "sha256:ee692e88515e9f78678b5cf9733df5b2f3daad40923a07bcfddb19865b9719cc"},
+    {file = "confluent_kafka-2.6.2-cp311-cp311-macosx_10_9_x86_64.whl", hash = "sha256:b438f8875d14977510d7f7682a51aa5d6b5165337afa97fa217b60dbbe329f92"},
+    {file = "confluent_kafka-2.6.2-cp311-cp311-macosx_11_0_arm64.whl", hash = "sha256:06e6eecaf8c545fcbc18695fa4f590eda1173388c065e1cf94da45a362515a2e"},
+    {file = "confluent_kafka-2.6.2-cp311-cp311-manylinux_2_28_aarch64.whl", hash = "sha256:69b4268f96a6076d9d9869ca2a059ca2474e1c24d1299882239ca1e2b236a430"},
+    {file = "confluent_kafka-2.6.2-cp311-cp311-manylinux_2_28_x86_64.whl", hash = "sha256:3594b5a49d6b9b3866c0ebb004ddbce51f829946ae7723b5b7de0ef15e190ff1"},
+    {file = "confluent_kafka-2.6.2-cp311-cp311-win_amd64.whl", hash = "sha256:b0efa6411dda0e1e5f8fe2bf36b7fd4b8106ef402515a8644adc1b0a30f19612"},
+    {file = "confluent_kafka-2.6.2-cp312-cp312-macosx_10_9_x86_64.whl", hash = "sha256:af91d4abcde3c356af944edd85d6b77bbee5e067395ba67e4886c554f66a1fcb"},
+    {file = "confluent_kafka-2.6.2-cp312-cp312-macosx_11_0_arm64.whl", hash = "sha256:63049405210933cf4937ef6918aa72dbf478e6e1c8c16572a5b52707bddc4398"},
+    {file = "confluent_kafka-2.6.2-cp312-cp312-manylinux_2_28_aarch64.whl", hash = "sha256:5df4dc36e5d7ac6d80128be3772560483e37115c46d52425a93cf6af54438859"},
+    {file = "confluent_kafka-2.6.2-cp312-cp312-manylinux_2_28_x86_64.whl", hash = "sha256:0be8ef210e471ef9486ae540c2ab63f84c632b4ba3e082a91773793888a19cef"},
+    {file = "confluent_kafka-2.6.2-cp312-cp312-win_amd64.whl", hash = "sha256:df5de463f30e6d31c39af27575d4ccac8d7197fc6ca104d09add8e92bfa899f1"},
+    {file = "confluent_kafka-2.6.2-cp313-cp313-macosx_13_0_arm64.whl", hash = "sha256:540e12ad274c507f06e388f6afd307572e3e720d0e56788816973f3632a61059"},
+    {file = "confluent_kafka-2.6.2-cp313-cp313-macosx_13_0_x86_64.whl", hash = "sha256:405c8a641b0e64df5574f77850b47500466e09e2bd7b0eb2f0b8a87fde690c5c"},
+    {file = "confluent_kafka-2.6.2-cp313-cp313-manylinux_2_28_aarch64.whl", hash = "sha256:9348ef89fdc16f5a1bdd458f4bc67d4bc0f4ec4f74081f48fddd74c1be571e9b"},
+    {file = "confluent_kafka-2.6.2-cp313-cp313-manylinux_2_28_x86_64.whl", hash = "sha256:a810c220cf429f7aafc8d39e0437e87868e19abbc9f1bcea58a15c870d09f08c"},
+    {file = "confluent_kafka-2.6.2-cp313-cp313-win_amd64.whl", hash = "sha256:962d48b098a8c840efe15c8d4c7750a8aed1e9819aa919bbc94a92835b49d02a"},
+    {file = "confluent_kafka-2.6.2-cp37-cp37m-macosx_10_9_x86_64.whl", hash = "sha256:75e88f60a027bb8828011ae23546f55949f1d92c8193e03a122b6931579da2c4"},
+    {file = "confluent_kafka-2.6.2-cp37-cp37m-manylinux_2_28_aarch64.whl", hash = "sha256:0fcc4a9b18ea087bbc4cc028bea38cb6125ef105ded8a08c4c526ff5c1bbc552"},
+    {file = "confluent_kafka-2.6.2-cp37-cp37m-manylinux_2_28_x86_64.whl", hash = "sha256:06148d58853609ae7a0312be88b02a44113361cc43e785c2d5a742724cc58686"},
+    {file = "confluent_kafka-2.6.2-cp37-cp37m-win_amd64.whl", hash = "sha256:de7825742b0d81d591703895650258546edb561476fe7ba6dab327d6bcbb1ce5"},
+    {file = "confluent_kafka-2.6.2-cp38-cp38-macosx_10_9_x86_64.whl", hash = "sha256:796bd69178d5ee72ea82f68c016c1666a17f78db735fe75d46c6e4db74c1963c"},
+    {file = "confluent_kafka-2.6.2-cp38-cp38-macosx_11_0_arm64.whl", hash = "sha256:3c54f0a0f8a08ac54536f618d72d617e11d5301a4e69c75d6113d3adad637955"},
+    {file = "confluent_kafka-2.6.2-cp38-cp38-manylinux_2_28_aarch64.whl", hash = "sha256:514b3dec3e0fd6a8f9e92936bd78479a3be57ca586a0ba5e68fa460aa3bcb608"},
+    {file = "confluent_kafka-2.6.2-cp38-cp38-manylinux_2_28_x86_64.whl", hash = "sha256:8f264fb04398a17e7b3c61b9d70f0bee15a538d077834269acdcfa54d0ad273e"},
+    {file = "confluent_kafka-2.6.2-cp38-cp38-win_amd64.whl", hash = "sha256:a0b1bc4023d3c248524d93e6fef2cfc875a82f872fb89c9513dd5ac0c384f910"},
+    {file = "confluent_kafka-2.6.2-cp39-cp39-macosx_10_9_x86_64.whl", hash = "sha256:0f03779a9b5c5a7767a49dbf4482f97d0f2ab0c85e4f9ffd4891c5933cc6d9be"},
+    {file = "confluent_kafka-2.6.2-cp39-cp39-macosx_11_0_arm64.whl", hash = "sha256:fe66720ff711d8d163f5b23970320c7b3ce89e044b09df81bea13659f11c354d"},
+    {file = "confluent_kafka-2.6.2-cp39-cp39-manylinux_2_28_aarch64.whl", hash = "sha256:86094674866350b39e3947631d88cb7ef93c27110f91093fc159e2a18be60021"},
+    {file = "confluent_kafka-2.6.2-cp39-cp39-manylinux_2_28_x86_64.whl", hash = "sha256:0403efc150c8ca6b1e213be1ca82ce8e385393586e93a480a81ebd9d2beb9fc6"},
+    {file = "confluent_kafka-2.6.2-cp39-cp39-win_amd64.whl", hash = "sha256:d7e843ebdb8cb9e2b83048002f22ba9c0fa94f04c024a6bdf515d71ecf0a5c0e"},
+    {file = "confluent_kafka-2.6.2.tar.gz", hash = "sha256:d36cc04548599a74d7757420704f3443ca6192cd82a524f493ae299b9ac8ed81"},
 ]
 
 [package.extras]
-avro = ["avro (>=1.11.1,<2)", "fastavro (>=0.23.0,<1.0)", "fastavro (>=1.0)", "requests"]
-dev = ["avro (>=1.11.1,<2)", "fastavro (>=0.23.0,<1.0)", "fastavro (>=1.0)", "flake8", "pytest", "pytest (==4.6.4)", "pytest-timeout", "requests"]
-doc = ["avro (>=1.11.1,<2)", "fastavro (>=0.23.0,<1.0)", "fastavro (>=1.0)", "requests", "sphinx", "sphinx-rtd-theme"]
-json = ["jsonschema", "pyrsistent", "pyrsistent (==0.16.1)", "requests"]
-protobuf = ["protobuf", "requests"]
-schema-registry = ["requests"]
+all = ["attrs", "attrs", "avro (>=1.11.1,<2)", "avro (>=1.11.1,<2)", "azure-identity", "azure-identity", "azure-keyvault-keys", "azure-keyvault-keys", "boto3", "boto3", "cachetools", "cachetools", "cel-python (>=0.1.5)", "cel-python (>=0.1.5)", "confluent-kafka", "fastapi", "fastavro (<1.8.0)", "fastavro (<1.8.0)", "fastavro (<2)", "fastavro (<2)", "flake8", "google-api-core", "google-api-core", "google-auth", "google-auth", "google-cloud-kms", "google-cloud-kms", "hkdf (==0.0.3)", "hkdf (==0.0.3)", "httpx (<0.28.0)", "httpx (<0.28.0)", "hvac", "hvac", "jsonata-python", "jsonata-python", "jsonschema", "jsonschema", "opentelemetry-distro", "opentelemetry-exporter-otlp", "protobuf", "protobuf", "psutil", "pydantic", "pyrsistent", "pyrsistent", "pytest", "pytest-timeout", "pyyaml (>=6.0.0)", "pyyaml (>=6.0.0)", "requests", "requests", "requests-mock", "respx", "six", "sphinx", "sphinx-rtd-theme", "tink", "tink", "urllib3 (<2.0.0)", "urllib3 (>=2.0.0,<3)", "uvicorn"]
+avro = ["attrs", "avro (>=1.11.1,<2)", "cachetools", "fastavro (<1.8.0)", "fastavro (<2)", "httpx (<0.28.0)", "requests"]
+dev = ["attrs", "attrs", "avro (>=1.11.1,<2)", "avro (>=1.11.1,<2)", "azure-identity", "azure-identity", "azure-keyvault-keys", "azure-keyvault-keys", "boto3", "boto3", "cachetools", "cachetools", "cel-python (>=0.1.5)", "cel-python (>=0.1.5)", "confluent-kafka", "fastapi", "fastavro (<1.8.0)", "fastavro (<1.8.0)", "fastavro (<2)", "fastavro (<2)", "flake8", "google-api-core", "google-api-core", "google-auth", "google-auth", "google-cloud-kms", "google-cloud-kms", "hkdf (==0.0.3)", "hkdf (==0.0.3)", "httpx (<0.28.0)", "httpx (<0.28.0)", "hvac", "hvac", "jsonata-python", "jsonata-python", "jsonschema", "jsonschema", "protobuf", "protobuf", "pydantic", "pyrsistent", "pyrsistent", "pytest", "pytest-timeout", "pyyaml (>=6.0.0)", "pyyaml (>=6.0.0)", "requests", "requests", "requests-mock", "respx", "six", "sphinx", "sphinx-rtd-theme", "tink", "tink", "urllib3 (<2.0.0)", "urllib3 (>=2.0.0,<3)", "uvicorn"]
+docs = ["attrs", "avro (>=1.11.1,<2)", "azure-identity", "azure-keyvault-keys", "boto3", "cachetools", "cel-python (>=0.1.5)", "fastavro (<1.8.0)", "fastavro (<2)", "google-api-core", "google-auth", "google-cloud-kms", "hkdf (==0.0.3)", "httpx (<0.28.0)", "hvac", "jsonata-python", "jsonschema", "protobuf", "pyrsistent", "pyyaml (>=6.0.0)", "requests", "sphinx", "sphinx-rtd-theme", "tink"]
+examples = ["attrs", "avro (>=1.11.1,<2)", "azure-identity", "azure-keyvault-keys", "boto3", "cachetools", "cel-python (>=0.1.5)", "confluent-kafka", "fastapi", "fastavro (<1.8.0)", "fastavro (<2)", "google-api-core", "google-auth", "google-cloud-kms", "hkdf (==0.0.3)", "httpx (<0.28.0)", "hvac", "jsonata-python", "jsonschema", "protobuf", "pydantic", "pyrsistent", "pyyaml (>=6.0.0)", "requests", "six", "tink", "uvicorn"]
+json = ["attrs", "cachetools", "httpx (<0.28.0)", "jsonschema", "pyrsistent"]
+protobuf = ["attrs", "cachetools", "httpx (<0.28.0)", "protobuf"]
+rules = ["attrs", "azure-identity", "azure-keyvault-keys", "boto3", "cachetools", "cel-python (>=0.1.5)", "google-api-core", "google-auth", "google-cloud-kms", "hkdf (==0.0.3)", "httpx (<0.28.0)", "hvac", "jsonata-python", "pyyaml (>=6.0.0)", "tink"]
+schemaregistry = ["attrs", "cachetools", "httpx (<0.28.0)"]
+soaktest = ["opentelemetry-distro", "opentelemetry-exporter-otlp", "psutil"]
+tests = ["attrs", "avro (>=1.11.1,<2)", "azure-identity", "azure-keyvault-keys", "boto3", "cachetools", "cel-python (>=0.1.5)", "fastavro (<1.8.0)", "fastavro (<2)", "flake8", "google-api-core", "google-auth", "google-cloud-kms", "hkdf (==0.0.3)", "httpx (<0.28.0)", "hvac", "jsonata-python", "jsonschema", "protobuf", "pyrsistent", "pytest", "pytest-timeout", "pyyaml (>=6.0.0)", "requests", "requests-mock", "respx", "tink", "urllib3 (<2.0.0)", "urllib3 (>=2.0.0,<3)"]
 
 [[package]]
 name = "cookiecutter"