This is an automated email from the ASF dual-hosted git repository.

dominikriemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to refs/heads/dev by this push:
     new 1e8aaf67b5 chore(deps): bump confluent-kafka from 2.15.0 to 2.16.1 in 
/streampipes-client-python (#5160)
1e8aaf67b5 is described below

commit 1e8aaf67b5ef01889589912fe955e2d0272f59ff
Author: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
AuthorDate: Fri Oct 30 07:16:00 2026 +0100

    chore(deps): bump confluent-kafka from 2.15.0 to 2.16.1 in 
/streampipes-client-python (#5160)
    
    Signed-off-by: dependabot[bot] <[email protected]>
    Co-authored-by: dependabot[bot] 
<49699333+dependabot[bot]@users.noreply.github.com>
---
 streampipes-client-python/poetry.lock    | 113 +++++++++++++++++--------------
 streampipes-client-python/pyproject.toml |   2 +-
 2 files changed, 64 insertions(+), 51 deletions(-)

diff --git a/streampipes-client-python/poetry.lock 
b/streampipes-client-python/poetry.lock
index 368b2a0472..cc56d71c9c 100644
--- a/streampipes-client-python/poetry.lock
+++ b/streampipes-client-python/poetry.lock
@@ -569,68 +569,81 @@ test = ["pytest"]
 
 [[package]]
 name = "confluent-kafka"
-version = "2.15.0"
+version = "2.16.1"
 description = "Confluent's Python client for Apache Kafka"
 optional = false
 python-versions = ">=3.8"
 groups = ["main"]
 files = [
-    {file = "confluent_kafka-2.15.0-cp310-cp310-macosx_10_9_x86_64.whl", hash 
= "sha256:f8ac4addda1cff47adc316146ee74aa2a83eeef14b176252f6f1abd29ae1d5a2"},
-    {file = "confluent_kafka-2.15.0-cp310-cp310-macosx_11_0_arm64.whl", hash = 
"sha256:64c5a9dbe563c964e21a83f3cb4ff1de6536e484a56289fe9aff69fc33302c73"},
-    {file = "confluent_kafka-2.15.0-cp310-cp310-manylinux_2_28_aarch64.whl", 
hash = 
"sha256:f4a8f02dbc93f17e125a201c5e5ce2143794b71bb5c91836ef87959fc5dcf6a4"},
-    {file = "confluent_kafka-2.15.0-cp310-cp310-manylinux_2_28_x86_64.whl", 
hash = 
"sha256:d9c9d240b681427568d9e341cf3deb3b7350b69931e6fbc636c5986432fb03f4"},
-    {file = "confluent_kafka-2.15.0-cp310-cp310-win_amd64.whl", hash = 
"sha256:039444ea430aaef415487df406070f364d956d76bbd980337455c2a7b5c5789b"},
-    {file = "confluent_kafka-2.15.0-cp311-cp311-macosx_10_9_x86_64.whl", hash 
= "sha256:3c4493caf1f1d2e295f5be8400d3a9854016456241f7062d0fb22dd01e2632e6"},
-    {file = "confluent_kafka-2.15.0-cp311-cp311-macosx_11_0_arm64.whl", hash = 
"sha256:c311695a10cefc1579372bd2f3808d28fd0c3d8cc7f578c94a381f351018912e"},
-    {file = "confluent_kafka-2.15.0-cp311-cp311-manylinux_2_28_aarch64.whl", 
hash = 
"sha256:7868fe2c2e1f6434903e3f1ea0ba6976d9382f5a9ef46f85d205ca7eb6f28689"},
-    {file = "confluent_kafka-2.15.0-cp311-cp311-manylinux_2_28_x86_64.whl", 
hash = 
"sha256:e31bbb5775da23f14264b3e6efd3839c1611a639f3d8c15516350798fe6f2750"},
-    {file = "confluent_kafka-2.15.0-cp311-cp311-win_amd64.whl", hash = 
"sha256:c041b784f25d2b0b8b2abab7390020951229b694a5c037402c493b0eeca12020"},
-    {file = "confluent_kafka-2.15.0-cp312-cp312-macosx_10_9_x86_64.whl", hash 
= "sha256:6e5ea2933c0b07782a99dfdfc9d52e92526e7a61839a6994feb994dcf2a78a74"},
-    {file = "confluent_kafka-2.15.0-cp312-cp312-macosx_11_0_arm64.whl", hash = 
"sha256:e4465a060ab215d5d514b181f3e7502c6fd7887529381c4af940a0b60f9d65cc"},
-    {file = "confluent_kafka-2.15.0-cp312-cp312-manylinux_2_28_aarch64.whl", 
hash = 
"sha256:b68e6f441866542c9150e6fdf106131eee5a51db591937888c866d799fb354ec"},
-    {file = "confluent_kafka-2.15.0-cp312-cp312-manylinux_2_28_x86_64.whl", 
hash = 
"sha256:fd833dab1392f456b9dd52b7ed9ac65b2cc36871ed5e3ebe8d53486c965b6453"},
-    {file = "confluent_kafka-2.15.0-cp312-cp312-win_amd64.whl", hash = 
"sha256:2cc8d01a77c534669bb896f731c8917cd63b787618081fdd0d1420d58cd6815b"},
-    {file = "confluent_kafka-2.15.0-cp313-cp313-macosx_13_0_arm64.whl", hash = 
"sha256:ff43508f8e929d83545272ef4f17e27fdaa9cc8397f77cf2236b22d67de4edc4"},
-    {file = "confluent_kafka-2.15.0-cp313-cp313-macosx_13_0_x86_64.whl", hash 
= "sha256:41d4c7360c51202785e8e9aa56241dd392b9dbcc311eae7c5e6985b239efc12b"},
-    {file = "confluent_kafka-2.15.0-cp313-cp313-manylinux_2_28_aarch64.whl", 
hash = 
"sha256:b0ac3831aac47ea23699a6ca5b9836288a4b9d201015dbfc4c3ec9f20592fdb5"},
-    {file = "confluent_kafka-2.15.0-cp313-cp313-manylinux_2_28_x86_64.whl", 
hash = 
"sha256:0455754e8294e1e76cb5acc083c300b6bd8d88f2d2c551c583cbf4ab55889a57"},
-    {file = "confluent_kafka-2.15.0-cp313-cp313-win_amd64.whl", hash = 
"sha256:7c59ea36606e0e946e6b353203136b4d71be6d95c0c8ae5113b81850ff5b7b41"},
-    {file = "confluent_kafka-2.15.0-cp314-cp314-macosx_13_0_arm64.whl", hash = 
"sha256:e781d39ff31d5d10d0502471f92f95aff4f5be1eaae9a1f57aeac164bc9f9029"},
-    {file = "confluent_kafka-2.15.0-cp314-cp314-macosx_13_0_x86_64.whl", hash 
= "sha256:000463c822a7adc3293369b63688b68d17c03a1a4a64f86182efc08f8b150676"},
-    {file = "confluent_kafka-2.15.0-cp314-cp314-manylinux_2_28_aarch64.whl", 
hash = 
"sha256:9ddf4cf4647e5d633ef64e3f5a349d5288edfedf974203993e9d86548c2695be"},
-    {file = "confluent_kafka-2.15.0-cp314-cp314-manylinux_2_28_x86_64.whl", 
hash = 
"sha256:d8ed33f623ff2a104fb76f99a67e9917f0170fddb4e28380fcdc83347b1646b2"},
-    {file = "confluent_kafka-2.15.0-cp314-cp314-win_amd64.whl", hash = 
"sha256:2e80bd96f61aae2ffba951754a769e6d3c5ebb5a5e778ed0ae8ad899ea91556b"},
-    {file = "confluent_kafka-2.15.0-cp38-cp38-macosx_10_9_x86_64.whl", hash = 
"sha256:5d80667060bac18eaa0a4821a7f162e96e0515d0b4b42e9d3725abc5782780d7"},
-    {file = "confluent_kafka-2.15.0-cp38-cp38-macosx_11_0_arm64.whl", hash = 
"sha256:59e88b759f256751fca7d5702fd6f892d9f5ee7710ecc37a4e1b38f6336b0383"},
-    {file = "confluent_kafka-2.15.0-cp38-cp38-manylinux_2_28_aarch64.whl", 
hash = 
"sha256:c620043e21a7f7c0f21e034f9785eb4b827ea1f6236740b7a7d8e829c14e58c4"},
-    {file = "confluent_kafka-2.15.0-cp38-cp38-manylinux_2_28_x86_64.whl", hash 
= "sha256:143ebab2df504775edd220406ab0e9476357d71fb679a049dd3b33badbc0872e"},
-    {file = "confluent_kafka-2.15.0-cp38-cp38-win_amd64.whl", hash = 
"sha256:3dd735d1a148e1f566097910d23293ee0898bf4853ad472d10c65751239c7e91"},
-    {file = "confluent_kafka-2.15.0-cp39-cp39-macosx_10_9_x86_64.whl", hash = 
"sha256:aadfa1f49fd770fe665662a8ae9670ae8c62ff2c360fed5aff0ddb54b4d39638"},
-    {file = "confluent_kafka-2.15.0-cp39-cp39-macosx_11_0_arm64.whl", hash = 
"sha256:ff6d0041e7d5318af548d90d67bb3a72410a77fe616a05564c3fa1ea13f23453"},
-    {file = "confluent_kafka-2.15.0-cp39-cp39-manylinux_2_28_aarch64.whl", 
hash = 
"sha256:537e6322f91e5077a6aa275ab1a9ceb4eaf0f85e1a2a711aa71e81a56dd95de7"},
-    {file = "confluent_kafka-2.15.0-cp39-cp39-manylinux_2_28_x86_64.whl", hash 
= "sha256:9edccce72df3c13d1dbdba0e1f95b9332eab08d4715b1bc9cfa5d45a92f9d11c"},
-    {file = "confluent_kafka-2.15.0-cp39-cp39-win_amd64.whl", hash = 
"sha256:31b8cc57794c0f048a6875280397bf4970744afe743d2d2208247a2f63ec8c7f"},
-    {file = "confluent_kafka-2.15.0.tar.gz", hash = 
"sha256:7ad9bad1cbabf6713ec039b8204b48d322024fd11397eec88d912e048c732ba7"},
+    {file = "confluent_kafka-2.16.1-cp310-cp310-macosx_10_9_x86_64.whl", hash 
= "sha256:6b05d8330289735f1035285a14c3b6d262abe13bca64adbdf3908350182bf4a9"},
+    {file = "confluent_kafka-2.16.1-cp310-cp310-macosx_11_0_arm64.whl", hash = 
"sha256:da265690af79296a3fd2d469c6768dd5334cb2f8ff54a2833690f82faae83835"},
+    {file = "confluent_kafka-2.16.1-cp310-cp310-manylinux_2_28_aarch64.whl", 
hash = 
"sha256:6c50cc9ec1c681c97edcf4f4cef6e7a7aee4f4db3812390460c4b35a73fd0e7b"},
+    {file = "confluent_kafka-2.16.1-cp310-cp310-manylinux_2_28_s390x.whl", 
hash = 
"sha256:03c87d997f4514c746edebc751110af71d8799db8ba9314a5169f0263a43e1c9"},
+    {file = "confluent_kafka-2.16.1-cp310-cp310-manylinux_2_28_x86_64.whl", 
hash = 
"sha256:5c5315512475f1b029b0cc1483a811a2263fa0907f61ebd0e27ff7acc5ce86e2"},
+    {file = "confluent_kafka-2.16.1-cp310-cp310-win_amd64.whl", hash = 
"sha256:0c35f0f682e5835b9c04a21ac1fd4d924878a14fc03707f7ad8040bca0861396"},
+    {file = "confluent_kafka-2.16.1-cp311-cp311-macosx_10_9_x86_64.whl", hash 
= "sha256:6e089a1f561ad08faee2c27f5b3c17de24761880945d1ac2c327c5e245c719ab"},
+    {file = "confluent_kafka-2.16.1-cp311-cp311-macosx_11_0_arm64.whl", hash = 
"sha256:8b8a8d34d5e6586997606e7e6f07885330f45b05580f4e77eb275b7b5d3a7eda"},
+    {file = "confluent_kafka-2.16.1-cp311-cp311-manylinux_2_28_aarch64.whl", 
hash = 
"sha256:c012a1d74f95e91c9c43f0aa996d5fea8582397144c1f96b553f24b594afa7c6"},
+    {file = "confluent_kafka-2.16.1-cp311-cp311-manylinux_2_28_s390x.whl", 
hash = 
"sha256:38fc4868bbd66c2242a36173952f5b2f6d1f7e62b43b4648015cbf57bd169328"},
+    {file = "confluent_kafka-2.16.1-cp311-cp311-manylinux_2_28_x86_64.whl", 
hash = 
"sha256:24f613cc81a856b6fbb2d7d11044a9aa770044eecc1f83ff84618688b056be06"},
+    {file = "confluent_kafka-2.16.1-cp311-cp311-win_amd64.whl", hash = 
"sha256:bf917cc9a980228516ae5472ffb6f975bf5a43a6159b02e3b581d969942160c7"},
+    {file = "confluent_kafka-2.16.1-cp312-cp312-macosx_10_9_x86_64.whl", hash 
= "sha256:11677c2318afe589135f87c3f0eda7d1960b5f9deafd341a17c157322fcc77f8"},
+    {file = "confluent_kafka-2.16.1-cp312-cp312-macosx_11_0_arm64.whl", hash = 
"sha256:ef8b8ea6b237aec595f5254b59a37e1cf5f0b7851b6739afa93ed0bb1c0be77f"},
+    {file = "confluent_kafka-2.16.1-cp312-cp312-manylinux_2_28_aarch64.whl", 
hash = 
"sha256:9deb0aa8920d567d09dd6258db6428f16ab9d229ee93aaf35a014aec771c2500"},
+    {file = "confluent_kafka-2.16.1-cp312-cp312-manylinux_2_28_s390x.whl", 
hash = 
"sha256:3365eb68d0c645209cdc6af0b4db9100a11e6032c07a3606f8f703eaa24529ee"},
+    {file = "confluent_kafka-2.16.1-cp312-cp312-manylinux_2_28_x86_64.whl", 
hash = 
"sha256:fdb2c4d53e84e10f4e567f4e74bba45d0ce90276b81259c3fc58df6960caabf5"},
+    {file = "confluent_kafka-2.16.1-cp312-cp312-win_amd64.whl", hash = 
"sha256:5d61d8214453d31cceb438b9dfc03bdd078ceeeac742d970990dd2dfc398e4aa"},
+    {file = "confluent_kafka-2.16.1-cp313-cp313-macosx_13_0_arm64.whl", hash = 
"sha256:c3bc184e79395eee26ffe73c9a041b5c68dd38ee1f90e0e7fffba89e02ab2ce0"},
+    {file = "confluent_kafka-2.16.1-cp313-cp313-macosx_13_0_x86_64.whl", hash 
= "sha256:f54e5c5d575a748d45e28f750ad48f41a06fa69e53c04c0ad2f51393015c8af6"},
+    {file = "confluent_kafka-2.16.1-cp313-cp313-manylinux_2_28_aarch64.whl", 
hash = 
"sha256:11ee0404517037d8b3248944fe19c733ee16e4cb2526d9c92cd5aee687a8504e"},
+    {file = "confluent_kafka-2.16.1-cp313-cp313-manylinux_2_28_s390x.whl", 
hash = 
"sha256:f1eca005def5e8cff1a0b1c4105c877c1f3114d8bbde44a31fd660a0758aa3dd"},
+    {file = "confluent_kafka-2.16.1-cp313-cp313-manylinux_2_28_x86_64.whl", 
hash = 
"sha256:ea772c30cfa618fcdfbc25756e3f7b4c5a221b0bffda98031293f8ffb7169609"},
+    {file = "confluent_kafka-2.16.1-cp313-cp313-win_amd64.whl", hash = 
"sha256:bb9b39aa28c2f33c8118aff3af9a0f5c851b426558305399c2939d0c1b9ce9df"},
+    {file = "confluent_kafka-2.16.1-cp314-cp314-macosx_13_0_arm64.whl", hash = 
"sha256:584ac27f6eadccbb74bea7cfbc60f5113262ad48542e9ae77d8571e790a7910d"},
+    {file = "confluent_kafka-2.16.1-cp314-cp314-macosx_13_0_x86_64.whl", hash 
= "sha256:b6fefffb769b6cadb748acb96855f40fe9aaebdc9b117542080dd2eb52137796"},
+    {file = "confluent_kafka-2.16.1-cp314-cp314-manylinux_2_28_aarch64.whl", 
hash = 
"sha256:4be5eecc098288ea6cf76762198404ee5b6827b389bb152d90f51b3d2ddbda1f"},
+    {file = "confluent_kafka-2.16.1-cp314-cp314-manylinux_2_28_s390x.whl", 
hash = 
"sha256:78f47110ed072d40bd0552f911f7ac8c342df5c2ef12670dcce1c61f1d930732"},
+    {file = "confluent_kafka-2.16.1-cp314-cp314-manylinux_2_28_x86_64.whl", 
hash = 
"sha256:e64a9a6c8b1d19cd7df418cacc0bbcd8491664ea5840b3e402e450031ff5ede7"},
+    {file = "confluent_kafka-2.16.1-cp314-cp314-win_amd64.whl", hash = 
"sha256:a3e2ef7a7b1d61028d69c3c94a88377e49c30df62120234cbecebd5448a500ca"},
+    {file = "confluent_kafka-2.16.1-cp314-cp314t-macosx_13_0_arm64.whl", hash 
= "sha256:0506927f2d8878affe7e296ba61909cd275a26fd687aa308e54eda72b31c3873"},
+    {file = "confluent_kafka-2.16.1-cp314-cp314t-macosx_13_0_x86_64.whl", hash 
= "sha256:8ccca6de07081fc8810d0f191900a88616b4462769dee48a1f70aec35abf6d36"},
+    {file = "confluent_kafka-2.16.1-cp314-cp314t-manylinux_2_28_aarch64.whl", 
hash = 
"sha256:b48f2e4469bb97e1c940308a59d16e91f7c09df3e97ed9856f50f614e3975f89"},
+    {file = "confluent_kafka-2.16.1-cp314-cp314t-manylinux_2_28_s390x.whl", 
hash = 
"sha256:579d32a1b035da695995707a8b6a6596d939994a8e5b29c59d3ce142b1fc52c1"},
+    {file = "confluent_kafka-2.16.1-cp314-cp314t-manylinux_2_28_x86_64.whl", 
hash = 
"sha256:be0c44dd5c5fe277e623fb816a4e098115c22ab91a370de751594c79bd573ee8"},
+    {file = "confluent_kafka-2.16.1-cp314-cp314t-win_amd64.whl", hash = 
"sha256:ac5f24df65727d9eac0f634002d43bc7e7a13558c7b2a13d72401db126324d41"},
+    {file = "confluent_kafka-2.16.1-cp38-cp38-macosx_10_9_x86_64.whl", hash = 
"sha256:cbbd58eb07df5fe27faeb54312b5c7c7822818edf70ce406f8a5e3d2d71863a8"},
+    {file = "confluent_kafka-2.16.1-cp38-cp38-macosx_11_0_arm64.whl", hash = 
"sha256:fbe7f8e946f7b557ea4ce545f5702c30b1d72aae041747ed83dc8b010f7f7d3e"},
+    {file = "confluent_kafka-2.16.1-cp38-cp38-manylinux_2_28_aarch64.whl", 
hash = 
"sha256:90f50e59727d81f31a55766c67271ff2827a90a200efeee92204fa7f823e4dad"},
+    {file = "confluent_kafka-2.16.1-cp38-cp38-manylinux_2_28_s390x.whl", hash 
= "sha256:7c2f47c327364d08c26496da66e9ab2a07b21eccbc35beb277b3ee53d5d20e3d"},
+    {file = "confluent_kafka-2.16.1-cp38-cp38-manylinux_2_28_x86_64.whl", hash 
= "sha256:d3136107aee276dd8a4c81c40faa7d10e38af5f24635c8782d547c9bba5cbb1b"},
+    {file = "confluent_kafka-2.16.1-cp38-cp38-win_amd64.whl", hash = 
"sha256:3d53c02d2dde43af6b8c0a7c05bd223944758ce6db7d8bdac28fdc93395eac91"},
+    {file = "confluent_kafka-2.16.1-cp39-cp39-macosx_10_9_x86_64.whl", hash = 
"sha256:c326ac7464591c199aa360c21c4f4295e8bf977b65e12bf50d2051bb80a7ba25"},
+    {file = "confluent_kafka-2.16.1-cp39-cp39-macosx_11_0_arm64.whl", hash = 
"sha256:713e88c4d9b56a1aea6cf95b9773797e8086995746077af8460eac1949ef9258"},
+    {file = "confluent_kafka-2.16.1-cp39-cp39-manylinux_2_28_aarch64.whl", 
hash = 
"sha256:c4457a97942cd62075f873ed38e70493cf001cee334788279d0b8933d53d5b6f"},
+    {file = "confluent_kafka-2.16.1-cp39-cp39-manylinux_2_28_s390x.whl", hash 
= "sha256:3f74980ef76a58d9107c90d7de09f91e929a6d6ce319b3ba898d6a3798eb6808"},
+    {file = "confluent_kafka-2.16.1-cp39-cp39-manylinux_2_28_x86_64.whl", hash 
= "sha256:a16d4204c99647d973892eb048a9ecb274ba227a3bdee787e81ca7f43f583cc1"},
+    {file = "confluent_kafka-2.16.1-cp39-cp39-win_amd64.whl", hash = 
"sha256:e87787641ea67215e65490b1d628318eb449f3c2fc1a0d643032f8ac26a6a882"},
+    {file = "confluent_kafka-2.16.1.tar.gz", hash = 
"sha256:ec1474347615b9dd1bd0e269d37e31fa442782e67c4942661751e81b09d9f0c8"},
 ]
 
 [package.dependencies]
 typing-extensions = {version = "*", markers = "python_version < \"3.11\""}
 
 [package.extras]
-all = ["async-timeout", "attrs", "attrs", "attrs (>=21.2.0)", "authlib 
(>=1.0.0)", "authlib (>=1.0.0)", "avro (>=1.11.1,<2)", "avro (>=1.11.1,<2)", 
"azure-identity", "azure-identity", "azure-keyvault-keys", 
"azure-keyvault-keys", "black (>=24.0.0)", "boto3", "boto3 (>=1.35)", "boto3 
(>=1.42.25)", "cachetools", "cachetools (>=5.5.0)", "cel-python (>=0.4.0)", 
"cel-python (>=0.4.0)", "certifi", "confluent-kafka", "fastapi", "fastavro 
(>=1.5.4,<1.8.0) ; python_version == \"3.7\"", "fastavro  [...]
-avro = ["attrs (>=21.2.0)", "authlib (>=1.0.0)", "avro (>=1.11.1,<2)", 
"cachetools (>=5.5.0)", "certifi", "fastavro (>=1.5.4,<1.8.0) ; python_version 
== \"3.7\"", "fastavro (>=1.5.4,<2) ; python_version > \"3.7\"", "httpx 
(>=0.26)", "requests"]
-dev = ["async-timeout", "attrs", "attrs", "attrs (>=21.2.0)", "authlib 
(>=1.0.0)", "authlib (>=1.0.0)", "avro (>=1.11.1,<2)", "avro (>=1.11.1,<2)", 
"azure-identity", "azure-identity", "azure-keyvault-keys", 
"azure-keyvault-keys", "black (>=24.0.0)", "boto3", "boto3 (>=1.35)", "boto3 
(>=1.42.25)", "cachetools", "cachetools (>=5.5.0)", "cel-python (>=0.4.0)", 
"cel-python (>=0.4.0)", "certifi", "confluent-kafka", "fastapi", "fastavro 
(>=1.5.4,<1.8.0) ; python_version == \"3.7\"", "fastavro  [...]
-docs = ["attrs (>=21.2.0)", "authlib (>=1.0.0)", "avro (>=1.11.1,<2)", 
"azure-identity", "azure-keyvault-keys", "boto3 (>=1.35)", "cachetools 
(>=5.5.0)", "cel-python (>=0.4.0)", "certifi", "fastavro (>=1.5.4,<1.8.0) ; 
python_version == \"3.7\"", "fastavro (>=1.5.4,<2) ; python_version > \"3.7\"", 
"google-api-core", "google-auth", "google-cloud-kms", "google-re2 
(<1.1.20251105)", "googleapis-common-protos", "hkdf (==0.0.3)", "httpx 
(>=0.26)", "hvac", "jsonata-python", "jsonschema (>=4.18. [...]
-examples = ["attrs", "authlib (>=1.0.0)", "avro (>=1.11.1,<2)", 
"azure-identity", "azure-keyvault-keys", "boto3", "cachetools", "cel-python 
(>=0.4.0)", "confluent-kafka", "fastapi", "fastavro (>=1.5.4,<1.8.0) ; 
python_version == \"3.7\"", "fastavro (>=1.5.4,<2) ; python_version > \"3.7\"", 
"google-api-core", "google-auth", "google-cloud-kms", 
"googleapis-common-protos", "hkdf (==0.0.3)", "httpx (>=0.26)", "hvac", 
"jsonata-python", "jsonschema (>=4.18.0)", "protobuf", "pydantic", "pyyaml  
[...]
-json = ["attrs (>=21.2.0)", "authlib (>=1.0.0)", "cachetools (>=5.5.0)", 
"certifi", "httpx (>=0.26)", "jsonschema (>=4.18.0)"]
-json-fast = ["attrs (>=21.2.0)", "authlib (>=1.0.0)", "cachetools (>=5.5.0)", 
"certifi", "httpx (>=0.26)", "jsonschema (>=4.18.0)", "orjson (>=3.10)"]
+all = ["async-timeout", "attrs", "attrs", "attrs (>=21.2.0)", "authlib 
(>=1.0.0) ; python_version < \"3.10\"", "authlib (>=1.0.0) ; python_version < 
\"3.10\"", "authlib (>=1.8.0) ; python_version >= \"3.10\"", "authlib (>=1.8.0) 
; python_version >= \"3.10\"", "avro (>=1.11.1,<2)", "avro (>=1.11.1,<2)", 
"azure-identity", "azure-identity", "azure-keyvault-keys", 
"azure-keyvault-keys", "black (>=24.0.0)", "boto3", "boto3 (>=1.35)", "boto3 
(>=1.42.25)", "cachetools", "cachetools (>=5.5.0)",  [...]
+avro = ["attrs (>=21.2.0)", "authlib (>=1.0.0) ; python_version < \"3.10\"", 
"authlib (>=1.8.0) ; python_version >= \"3.10\"", "avro (>=1.11.1,<2)", 
"cachetools (>=5.5.0)", "certifi (>=2026.10.19)", "fastavro (>=1.5.4,<1.8.0) ; 
python_version == \"3.7\"", "fastavro (>=1.5.4,<2) ; python_version > \"3.7\"", 
"httpx (>=0.26) ; python_version < \"3.10\"", "httpx2 (>=2.0) ; python_version 
>= \"3.10\"", "requests"]
+dev = ["async-timeout", "attrs", "attrs", "attrs (>=21.2.0)", "authlib 
(>=1.0.0) ; python_version < \"3.10\"", "authlib (>=1.0.0) ; python_version < 
\"3.10\"", "authlib (>=1.8.0) ; python_version >= \"3.10\"", "authlib (>=1.8.0) 
; python_version >= \"3.10\"", "avro (>=1.11.1,<2)", "avro (>=1.11.1,<2)", 
"azure-identity", "azure-identity", "azure-keyvault-keys", 
"azure-keyvault-keys", "black (>=24.0.0)", "boto3", "boto3 (>=1.35)", "boto3 
(>=1.42.25)", "cachetools", "cachetools (>=5.5.0)",  [...]
+docs = ["attrs (>=21.2.0)", "authlib (>=1.0.0) ; python_version < \"3.10\"", 
"authlib (>=1.8.0) ; python_version >= \"3.10\"", "avro (>=1.11.1,<2)", 
"azure-identity", "azure-keyvault-keys", "boto3 (>=1.35)", "cachetools 
(>=5.5.0)", "cel-python (>=0.4.0)", "certifi (>=2026.10.19)", "fastavro 
(>=1.5.4,<1.8.0) ; python_version == \"3.7\"", "fastavro (>=1.5.4,<2) ; 
python_version > \"3.7\"", "google-api-core", "google-auth", 
"google-cloud-kms", "google-re2 (<1.1.20251105)", "googleapis-commo [...]
+examples = ["attrs", "authlib (>=1.0.0) ; python_version < \"3.10\"", "authlib 
(>=1.8.0) ; python_version >= \"3.10\"", "avro (>=1.11.1,<2)", 
"azure-identity", "azure-keyvault-keys", "boto3", "cachetools", "cel-python 
(>=0.4.0)", "confluent-kafka", "fastapi", "fastavro (>=1.5.4,<1.8.0) ; 
python_version == \"3.7\"", "fastavro (>=1.5.4,<2) ; python_version > \"3.7\"", 
"google-api-core", "google-auth", "google-cloud-kms", 
"googleapis-common-protos", "hkdf (==0.0.3)", "httpx (>=0.26) ; pytho [...]
+json = ["attrs (>=21.2.0)", "authlib (>=1.0.0) ; python_version < \"3.10\"", 
"authlib (>=1.8.0) ; python_version >= \"3.10\"", "cachetools (>=5.5.0)", 
"certifi (>=2026.10.19)", "httpx (>=0.26) ; python_version < \"3.10\"", "httpx2 
(>=2.0) ; python_version >= \"3.10\"", "jsonschema (>=4.18.0)"]
+json-fast = ["attrs (>=21.2.0)", "authlib (>=1.0.0) ; python_version < 
\"3.10\"", "authlib (>=1.8.0) ; python_version >= \"3.10\"", "cachetools 
(>=5.5.0)", "certifi (>=2026.10.19)", "httpx (>=0.26) ; python_version < 
\"3.10\"", "httpx2 (>=2.0) ; python_version >= \"3.10\"", "jsonschema 
(>=4.18.0)", "orjson (>=3.10)"]
 oauthbearer-aws = ["boto3 (>=1.42.25)"]
-protobuf = ["attrs (>=21.2.0)", "authlib (>=1.0.0)", "cachetools (>=5.5.0)", 
"certifi", "googleapis-common-protos", "httpx (>=0.26)", "protobuf"]
-rules = ["attrs (>=21.2.0)", "authlib (>=1.0.0)", "azure-identity", 
"azure-keyvault-keys", "boto3 (>=1.35)", "cachetools (>=5.5.0)", "cel-python 
(>=0.4.0)", "certifi", "google-api-core", "google-auth", "google-cloud-kms", 
"google-re2 (<1.1.20251105)", "hkdf (==0.0.3)", "httpx (>=0.26)", "hvac", 
"jsonata-python", "pyyaml (>=6.0.0)", "tink"]
-schema-registry = ["attrs (>=21.2.0)", "authlib (>=1.0.0)", "cachetools 
(>=5.5.0)", "certifi", "httpx (>=0.26)"]
-schemaregistry = ["attrs (>=21.2.0)", "authlib (>=1.0.0)", "cachetools 
(>=5.5.0)", "certifi", "httpx (>=0.26)"]
+protobuf = ["attrs (>=21.2.0)", "authlib (>=1.0.0) ; python_version < 
\"3.10\"", "authlib (>=1.8.0) ; python_version >= \"3.10\"", "cachetools 
(>=5.5.0)", "certifi (>=2026.10.19)", "googleapis-common-protos", "httpx 
(>=0.26) ; python_version < \"3.10\"", "httpx2 (>=2.0) ; python_version >= 
\"3.10\"", "protobuf"]
+rules = ["attrs (>=21.2.0)", "authlib (>=1.0.0) ; python_version < \"3.10\"", 
"authlib (>=1.8.0) ; python_version >= \"3.10\"", "azure-identity", 
"azure-keyvault-keys", "boto3 (>=1.35)", "cachetools (>=5.5.0)", "cel-python 
(>=0.4.0)", "certifi (>=2026.10.19)", "google-api-core", "google-auth", 
"google-cloud-kms", "google-re2 (<1.1.20251105)", "hkdf (==0.0.3)", "httpx 
(>=0.26) ; python_version < \"3.10\"", "httpx2 (>=2.0) ; python_version >= 
\"3.10\"", "hvac", "jsonata-python", "pyyaml (> [...]
+schema-registry = ["attrs (>=21.2.0)", "authlib (>=1.0.0) ; python_version < 
\"3.10\"", "authlib (>=1.8.0) ; python_version >= \"3.10\"", "cachetools 
(>=5.5.0)", "certifi (>=2026.10.19)", "httpx (>=0.26) ; python_version < 
\"3.10\"", "httpx2 (>=2.0) ; python_version >= \"3.10\""]
+schemaregistry = ["attrs (>=21.2.0)", "authlib (>=1.0.0) ; python_version < 
\"3.10\"", "authlib (>=1.8.0) ; python_version >= \"3.10\"", "cachetools 
(>=5.5.0)", "certifi (>=2026.10.19)", "httpx (>=0.26) ; python_version < 
\"3.10\"", "httpx2 (>=2.0) ; python_version >= \"3.10\""]
 soaktest = ["opentelemetry-distro", "opentelemetry-exporter-otlp", "psutil"]
-tests = ["async-timeout", "attrs", "attrs (>=21.2.0)", "authlib (>=1.0.0)", 
"avro (>=1.11.1,<2)", "azure-identity", "azure-keyvault-keys", "black 
(>=24.0.0)", "boto3 (>=1.35)", "boto3 (>=1.42.25)", "cachetools (>=5.5.0)", 
"cel-python (>=0.4.0)", "certifi", "fastavro (>=1.5.4,<1.8.0) ; python_version 
== \"3.7\"", "fastavro (>=1.5.4,<2) ; python_version > \"3.7\"", "flake8", 
"google-api-core", "google-auth", "google-cloud-kms", "google-re2 
(<1.1.20251105)", "googleapis-common-protos", "hkd [...]
+tests = ["async-timeout", "attrs", "attrs (>=21.2.0)", "authlib (>=1.0.0) ; 
python_version < \"3.10\"", "authlib (>=1.8.0) ; python_version >= \"3.10\"", 
"avro (>=1.11.1,<2)", "azure-identity", "azure-keyvault-keys", "black 
(>=24.0.0)", "boto3 (>=1.35)", "boto3 (>=1.42.25)", "cachetools (>=5.5.0)", 
"cel-python (>=0.4.0)", "certifi (>=2026.10.19)", "fastavro (>=1.5.4,<1.8.0) ; 
python_version == \"3.7\"", "fastavro (>=1.5.4,<2) ; python_version > \"3.7\"", 
"flake8", "google-api-core", "goo [...]
 
 [[package]]
 name = "coverage"
@@ -4789,4 +4802,4 @@ type = ["pytest-mypy"]
 [metadata]
 lock-version = "2.1"
 python-versions = ">=3.10"
-content-hash = 
"d9ac16da8d283a7fb96daaf178233fdfb4edcb895cba8d4defb099e492962872"
+content-hash = 
"af4095412c7f7b30d09c0afd325884efeb7143ffb2d76f2f734757fec66e049b"
diff --git a/streampipes-client-python/pyproject.toml 
b/streampipes-client-python/pyproject.toml
index a07f3daa7e..bab2f36ae2 100644
--- a/streampipes-client-python/pyproject.toml
+++ b/streampipes-client-python/pyproject.toml
@@ -24,7 +24,7 @@ authors = [
 ]
 requires-python = ">=3.10"
 dependencies = [
-    "confluent-kafka>=2.15.0,<3",
+    "confluent-kafka>=2.16.1,<3",
     "nats-py>=2.16.0,<3",
     "pandas>=2.3.3,<3",
     "pydantic>=2.14.1,<3.0.0",

Reply via email to