Bump confluent-kafka from 1.9.2 to 2.13.2 in /docker/confluent-kafka

[dependabot]

Bumps confluent-kafka from 1.9.2 to 2.13.2.

Release notes

Sourced from confluent-kafka's releases.

v2.13.2 is a maintenance release with the following fixes and enhancements:

Enhancements

• Add Confluent-Client-Version header to requests to SR, Python client (#2148)
• Add UAMI OAuth changes (#2189)

Fixes

• Fixed memory leak in Producer.produce() when called with headers and raises BufferError (queue full) or RuntimeError (producer closed). The allocated rd_headers memory is now properly freed in error paths before returning. Fixes Issue confluentinc/confluent-kafka-python#2167.
• Fixed type hinting of KafkaError class, Consumer.init(), Producer.init(), Producer.produce() and Consumer.commit() and introduced a script in tools directory to keep error codes up to date. Fixes Issue confluentinc/confluent-kafka-python#2168.
• Fix the token expiration logic in SR Oauth (#2177)
• Ensure use of cachetools is thread-safe (#2178)
• Remove passing resolver in json validate (#2186)
• Fix JSON schema resolver bug (#2188)

---

confluent-kafka-python v2.13.2 is based on librdkafka v2.13.2, see the librdkafka release notes for a complete list of changes, enhancements, fixes and upgrade considerations.

Installation

pip install confluent-kafka==2.13.2

v2.13.0 is a feature release with the following features, fixes and enhancements:

Enhancements

• Enforced type hinting for all interfaces
• Handle OAuth Token Refreshes using background thread for Admin, Producer and Consumer clients (#2130)
• Added black and isort linting rules and enforcement to codebase (#2133, #2137)
• Enabled direct creation of Message objects (#2128)
• Added close() method to producer (#2039)
• Added context manager for librdkafka classes to enable easy scope cleanup (#2114)
• Expose deterministic partitioner functions (#2116)
• Add Accept-Version header for schemas (#2117)
• Enhanced the BufferTimeoutManager to flush the librdkafka queue
• Remove experimental module designation for Async classes (#2143)
• Add __len__ function to AIOProducer (#2140)
• Enhance Message class to include serialisation support and rich comparison (#2153)
• Support Strict Validation Flags in Avro Serializers (#2147)

Fixes

• Type hint __enter__ to return the same object type that called it (#2157)
• Fixed Consumer.poll(), Consumer.consume(), Producer.poll(), and Producer.flush() blocking indefinitely and not responding to Ctrl+C (KeyboardInterrupt) signals. The implementation now uses a "wakeable poll" pattern that breaks long blocking calls into smaller chunks (200ms) and periodically re-acquires the Python GIL to check for pending signals. This allows Ctrl+C to properly interrupt blocking operations. Fixes Issues #209 and #807 (#2126).
• Fix support for wrapped Avro unions (#2134)
• Fixed segfault exceptions on calls against objects that had closed internal objects (#2122)
• Handle evolution during field transformation of schemas (#2121)
• Handle null group name to prevent segfault in Admin list_consumer_group_offsets() (#2118)
• Ensure schemaId initialization is thread-safe (#2120)

... (truncated)

Changelog

Sourced from confluent-kafka's changelog.

v2.13.2 - 2026-03-02

v2.13.2 is a maintenance release with the following fixes and enhancements:

Enhancements

• Add Confluent-Client-Version header to requests to SR, Python client (#2148)
• Add UAMI OAuth changes (#2189)

Fixes

• Fixed memory leak in Producer.produce() when called with headers and raises BufferError (queue full) or RuntimeError (producer closed). The allocated rd_headers memory is now properly freed in error paths before returning. Fixes Issue #2167.
• Fixed type hinting of KafkaError class, Consumer.__init()__, Producer.__init()__, Producer.produce() and Consumer.commit() and introduced a script in tools directory to keep error codes up to date. Fixes Issue #2168.
• Fix the token expiration logic in SR Oauth (#2177)
• Ensure use of cachetools is thread-safe (#2178)
• Remove passing resolver in json validate (#2186)
• Fix JSON schema resolver bug (#2188)

v2.13.0 - 2025-12-15

v2.13.0 is a feature release with the following features, fixes and enhancements:

Enhancements

• Enforced type hinting for all interfaces
• Handle OAuth Token Refreshes using background thread for Admin, Producer and Consumer clients (#2130)
• Added black and isort linting rules and enforcement to codebase (#2133, #2137)
• Enabled direct creation of Message objects (#2128)
• Added close() method to producer (#2039)
• Added context manager for librdkafka classes to enable easy scope cleanup (#2114)
• Expose deterministic partitioner functions (#2116)
• Add Accept-Version header for schemas (#2117)
• Enhanced the BufferTimeoutManager to flush the librdkafka queue
• Remove experimental module designation for Async classes (#2143)
• Add __len__ function to AIOProducer (#2140)
• Enhance Message class to include serialisation support and rich comparison (#2153)
• Support Strict Validation Flags in Avro Serializers (#2147)

Fixes

• Type hint __enter__ to return the same object type that called it (#2157)
• Fixed Consumer.poll(), Consumer.consume(), Producer.poll(), and Producer.flush() blocking indefinitely and not responding to Ctrl+C (KeyboardInterrupt) signals. The implementation now uses a "wakeable poll" pattern that breaks long blocking calls into smaller chunks (200ms) and periodically re-acquires the Python GIL to check for pending signals. This allows Ctrl+C to properly interrupt blocking operations. Fixes Issues #209 and #807 (#2126).
• Fix support for wrapped Avro unions (#2134)
• Fixed segfault exceptions on calls against objects that had closed internal objects (#2122)
• Handle evolution during field transformation of schemas (#2121)
• Handle null group name to prevent segfault in Admin list_consumer_group_offsets() (#2118)
• Ensure schemaId initialization is thread-safe (#2120)
• Fix error propagation rule for Python's C API
• Fix SR delete behavior with client-side caching

... (truncated)

Commits

• 1979093 Version changes for release 2.13.2 (#2207)
• 28871a2 Add release automation: pre-release validation, wheel verification, PyPI publ...
• b42ea4d Add update-changelog.py script (#2204)
• 12902cc Update CHANGELOG for 2.13.1 (#2203)
• 5bcde95 Fix Windows wheel build by using python instead of python3 (#2199)
• 1a91492 Use uv instead of pip during build (#2198)
• 8da582e Fix memory metric in ducktape tests and update max_memory_growth_mb threshold...
• 612349e Add UAMI OAuth changes (#2189)
• 35d5608 Fix JSON schema resolver bug (#2188)
• 0eac76f remove passing resolver in json validate (#2186)
• Additional commits viewable in compare view

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 commands and options

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)