dependabot[bot] opened a new pull request, #4699: URL: https://github.com/apache/streampipes/pull/4699
Bumps [confluent-kafka](https://github.com/confluentinc/confluent-kafka-python) from 2.14.2 to 2.15.0. <details> <summary>Release notes</summary> <p><em>Sourced from <a href="https://github.com/confluentinc/confluent-kafka-python/releases";>confluent-kafka's releases</a>.</em></p> <blockquote> <h2>v2.15.0</h2> <h2><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-932%3A+Queues+for+Kafka";>KIP-932</a> Queues for Kafka – Now in <strong>Preview</strong></h2> <p>confluent-kafka-python 2.15.0 adds a <strong>Preview</strong> implementation of the KIP-932 share consumer (Queues for Kafka). Members of a share group cooperatively consume from the same partitions with per-record acquire/acknowledge semantics and redelivery, providing queue-like consumption on top of Kafka.</p> <ul> <li>New <code>ShareConsumer</code> and <code>DeserializingShareConsumer</code> clients: subscribe, batch poll (<code>poll()</code> returns a <code>Messages</code> batch), and close (with context-manager support).</li> <li>Implicit (default) and explicit acknowledgement modes (<code>share.acknowledgement.mode</code>), with <code>AcknowledgeType</code> ACCEPT / RELEASE / REJECT and <code>Message.delivery_count()</code>.</li> <li>Synchronous and asynchronous commit (<code>commit_sync</code> / <code>commit_async</code>) and an acknowledgement-commit callback.</li> <li>Runtime SASL credential updates (<code>set_sasl_credentials</code>) and new <code>IllegalStateException</code> / <code>ConcurrentModificationException</code> exceptions.</li> <li>(<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2217";>#2217</a>, <a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2239";>#2239</a>, <a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2241";>#2241</a>, <a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2252";>#2252</a>, <a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2253";>#2253</a>, <a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2265";>#2265</a>, <a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2273";>#2273</a>, <a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2277";>#2277</a>, <a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2279";>#2279</a>)</li> </ul> <p>See the <a href="https://github.com/confluentinc/confluent-kafka-python/blob/HEAD/docs/kip-932-share-consumer.md";>Share Consumer guide</a> and the <a href="https://github.com/confluentinc/librdkafka/blob/master/INTRODUCTION.md#share-consumers-queues-for-kafka";>Share consumers section of librdkafka's INTRODUCTION.md</a>.</p> <p><strong>Note:</strong> The share consumer is currently in <strong>Preview</strong> and should not be used in production environments. Its public interfaces may change before General Availability, and known limitations apply (see the guide). The share consumer is single-threaded and not thread-safe. It requires a broker with share groups enabled (generally available in Apache Kafka 4.2.0).</p> <h3>Features</h3> <ul> <li>New optional install <code>confluent-kafka[oauthbearer-aws]</code> provides AWS IAM-based OAUTHBEARER authentication via AWS STS <code>GetWebIdentityToken</code>. Activate by setting <code>sasl.oauthbearer.method=oidc</code>, <code>sasl.oauthbearer.metadata.authentication.type=aws_iam</code>, and <code>sasl.oauthbearer.config="region=...,audience=..."</code>. See the <a href="https://github.com/confluentinc/confluent-kafka-python/blob/HEAD/docs/oauthbearer-aws.md";>AWS IAM OAUTHBEARER guide</a> for full configuration, and <a href="https://github.com/confluentinc/confluent-kafka-python/blob/HEAD/examples/oauth_oidc_ccloud_aws_iam.py";><code>https://github.com/confluentinc/confluent-kafka-python/blob/HEAD/examples/oauth_oidc_ccloud_aws_iam.py</code></a> for a worked example.</li> </ul> <h3>Enhancements</h3> <ul> <li>Add support for union-of-pools and auto pool mapping for Schema Registry (<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2182";>#2182</a>)</li> </ul> <h3>Fixes</h3> <ul> <li>Fix Encryption fails when expanded union types have two references to the same record (<a href="https://github.com/ChristophMajcenAtXxxlutz";><code>@ChristophMajcenAtXxxlutz</code></a>, <a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2262";>#2262</a>)</li> <li>Make orjson optional in JSON serdes with stdlib json fallback (<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2281";>#2281</a>)</li> <li>Handle non-http errors during retries (<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2292";>#2292</a>)</li> <li>Use TLS certification verification with Hashicorp Vault (<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2294";>#2294</a>)</li> </ul> <p>confluent-kafka-python v2.15.0 is based on librdkafka v2.15.0, see the <a href="https://github.com/confluentinc/librdkafka/releases/tag/v2.15.0";>librdkafka release notes</a> for a complete list of changes, enhancements, fixes and upgrade considerations.</p> </blockquote> </details> <details> <summary>Changelog</summary> <p><em>Sourced from <a href="https://github.com/confluentinc/confluent-kafka-python/blob/master/CHANGELOG.md";>confluent-kafka's changelog</a>.</em></p> <blockquote> <h2>v2.15.0</h2> <h3><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-932%3A+Queues+for+Kafka";>KIP-932</a> Queues for Kafka – Now in <strong>Preview</strong></h3> <p>confluent-kafka-python 2.15.0 adds a <strong>Preview</strong> implementation of the KIP-932 share consumer (Queues for Kafka). Members of a share group cooperatively consume from the same partitions with per-record acquire/acknowledge semantics and redelivery, providing queue-like consumption on top of Kafka.</p> <ul> <li>New <code>ShareConsumer</code> and <code>DeserializingShareConsumer</code> clients: subscribe, batch poll (<code>poll()</code> returns a <code>Messages</code> batch), and close (with context-manager support).</li> <li>Implicit (default) and explicit acknowledgement modes (<code>share.acknowledgement.mode</code>), with <code>AcknowledgeType</code> ACCEPT / RELEASE / REJECT and <code>Message.delivery_count()</code>.</li> <li>Synchronous and asynchronous commit (<code>commit_sync</code> / <code>commit_async</code>) and an acknowledgement-commit callback.</li> <li>Runtime SASL credential updates (<code>set_sasl_credentials</code>) and new <code>IllegalStateException</code> / <code>ConcurrentModificationException</code> exceptions.</li> <li>(<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2217";>#2217</a>, <a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2239";>#2239</a>, <a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2241";>#2241</a>, <a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2252";>#2252</a>, <a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2253";>#2253</a>, <a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2265";>#2265</a>, <a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2273";>#2273</a>, <a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2277";>#2277</a>, <a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2279";>#2279</a>)</li> </ul> <p>See the <a href="https://github.com/confluentinc/confluent-kafka-python/blob/master/docs/kip-932-share-consumer.md";>Share Consumer guide</a> and the <a href="https://github.com/confluentinc/librdkafka/blob/master/INTRODUCTION.md#share-consumers-queues-for-kafka";>Share consumers section of librdkafka's INTRODUCTION.md</a>.</p> <p><strong>Note:</strong> The share consumer is currently in <strong>Preview</strong> and should not be used in production environments. Its public interfaces may change before General Availability, and known limitations apply (see the guide). The share consumer is single-threaded and not thread-safe. It requires a broker with share groups enabled (generally available in Apache Kafka 4.2.0).</p> <h3>Features</h3> <ul> <li>New optional install <code>confluent-kafka[oauthbearer-aws]</code> provides AWS IAM-based OAUTHBEARER authentication via AWS STS <code>GetWebIdentityToken</code>. Activate by setting <code>sasl.oauthbearer.method=oidc</code>, <code>sasl.oauthbearer.metadata.authentication.type=aws_iam</code>, and <code>sasl.oauthbearer.config="region=...,audience=..."</code>. See the <a href="https://github.com/confluentinc/confluent-kafka-python/blob/master/docs/oauthbearer-aws.md";>AWS IAM OAUTHBEARER guide</a> for full configuration, and <a href="https://github.com/confluentinc/confluent-kafka-python/blob/master/examples/oauth_oidc_ccloud_aws_iam.py";><code>https://github.com/confluentinc/confluent-kafka-python/blob/master/examples/oauth_oidc_ccloud_aws_iam.py</code></a> for a worked example.</li> </ul> <h3>Enhancements</h3> <ul> <li>Add support for union-of-pools and auto pool mapping for Schema Registry (<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2182";>#2182</a>)</li> </ul> <h3>Fixes</h3> <ul> <li>Fix Encryption fails when expanded union types have two references to the same record (<a href="https://github.com/ChristophMajcenAtXxxlutz";><code>@ChristophMajcenAtXxxlutz</code></a>, <a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2262";>#2262</a>)</li> <li>Make orjson optional in JSON serdes with stdlib json fallback (<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2281";>#2281</a>)</li> <li>Handle non-http errors during retries (<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2292";>#2292</a>)</li> <li>Use TLS certification verification with Hashicorp Vault (<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2294";>#2294</a>)</li> </ul> <p>confluent-kafka-python v2.15.0 is based on librdkafka v2.15.0, see the <a href="https://github.com/confluentinc/librdkafka/releases/tag/v2.15.0";>librdkafka release notes</a> for a complete list of changes, enhancements, fixes and upgrade considerations.</p> </blockquote> </details> <details> <summary>Commits</summary> <ul> <li><a href="https://github.com/confluentinc/confluent-kafka-python/commit/8b1c7a613434eee3d0e1287d624d7af04932f410";><code>8b1c7a6</code></a> v2.15.0 (<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2302";>#2302</a>)</li> <li><a href="https://github.com/confluentinc/confluent-kafka-python/commit/ad3d77998225acb0672b3251773bdb482f7a48a1";><code>ad3d779</code></a> Update changelog (<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2301";>#2301</a>)</li> <li><a href="https://github.com/confluentinc/confluent-kafka-python/commit/ffbdc9f72fcd1137f07d70142c8b0885979bd7a0";><code>ffbdc9f</code></a> v2.15.0rc2 (<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2300";>#2300</a>)</li> <li><a href="https://github.com/confluentinc/confluent-kafka-python/commit/291f5b713edc5020e7c7fbe53c5afb4afd181d23";><code>291f5b7</code></a> [KIP-932] Share consumer (Queues for Kafka) guide and external docs (<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2298";>#2298</a>)</li> <li><a href="https://github.com/confluentinc/confluent-kafka-python/commit/cc51dc2227168570e79faa9ef26a488d983a4a9d";><code>cc51dc2</code></a> [KIP-932] - Update ShareConsumer api docs (<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2295";>#2295</a>)</li> <li><a href="https://github.com/confluentinc/confluent-kafka-python/commit/50e9228fd7ff0ae5c0e623a87cce4ed565fec93e";><code>50e9228</code></a> Harden HCVault KMS TLS verify against empty CA value; add tests (<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2296";>#2296</a>)</li> <li><a href="https://github.com/confluentinc/confluent-kafka-python/commit/19d1b98c9fa68a0ecfa762d2c75eecc173d89609";><code>19d1b98</code></a> Use TLS certification verification with Hashicorp Vault (<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2294";>#2294</a>)</li> <li><a href="https://github.com/confluentinc/confluent-kafka-python/commit/a697e38823bacb6adabae979d84e08578ed9381e";><code>a697e38</code></a> DGS-23437: Enable client omit Confluent-Identity-Pool-Id (<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2182";>#2182</a>)</li> <li><a href="https://github.com/confluentinc/confluent-kafka-python/commit/cc498ecaff4881d5088059b08d17629ba84c8430";><code>cc498ec</code></a> AWS IAM OAUTHBEARER support via optional <code>oauthbearer-aws</code> module (<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2267";>#2267</a>)</li> <li><a href="https://github.com/confluentinc/confluent-kafka-python/commit/b2edda31091455a4bbcaae486fe424d7a47a69a4";><code>b2edda3</code></a> [KIP-932] - Add usage examples for share consumer applications (<a href="https://redirect.github.com/confluentinc/confluent-kafka-python/issues/2288";>#2288</a>)</li> <li>Additional commits viewable in <a href="https://github.com/confluentinc/confluent-kafka-python/compare/v2.14.2...v2.15.0";>compare view</a></li> </ul> </details> <br /> [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a rebase manually by commenting `@dependabot rebase`. [//]: # (dependabot-automerge-start) [//]: # (dependabot-automerge-end) --- <details> <summary>Dependabot commands and options</summary> <br /> You can trigger Dependabot actions by commenting on this PR: - `@dependabot rebase` will rebase this PR - `@dependabot recreate` will recreate this PR, overwriting any edits that have been made to it - `@dependabot show <dependency name> ignore conditions` will show all of the ignore conditions of the specified dependency - `@dependabot ignore this major version` will close this PR and stop Dependabot creating any more for this major version (unless you reopen the PR or upgrade to it yourself) - `@dependabot ignore this minor version` will close this PR and stop Dependabot creating any more for this minor version (unless you reopen the PR or upgrade to it yourself) - `@dependabot ignore this dependency` will close this PR and stop Dependabot creating any more for this dependency (unless you reopen the PR or upgrade to it yourself) </details> -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
