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",