Skip to content

chore(deps): bump kafka-python from 2.0.6 to 2.3.2 in /dataflow/snippets - #14563

Open
dependabot[bot] wants to merge 1 commit into
mainfrom
dependabot/pip/dataflow/snippets/kafka-python-2.3.2
Open

chore(deps): bump kafka-python from 2.0.6 to 2.3.2 in /dataflow/snippets#14563
dependabot[bot] wants to merge 1 commit into
mainfrom
dependabot/pip/dataflow/snippets/kafka-python-2.3.2

Conversation

@dependabot

@dependabot dependabot Bot commented on behalf of github Sep 1, 2026

Copy link
Copy Markdown
Contributor

Bumps kafka-python from 2.0.6 to 2.3.2.

Release notes

Sourced from kafka-python's releases.

2.3.2 (Jun 3, 2026)

Fixes

  • kafka.conn: Improve error handling for sasl authenticate mechanisms
  • kafka.net: Validate SASL/SCRAM iterations (#3026)
  • KafkaProtocol: validate network frame size (backport of #3019)
  • Clear _callbacks/_errbacks list when future is_done to avoid reference cycles (#2891)

2.3.1 (Apr 9, 2026)

Fixes

  • Fix TaggedFields value encoding; add test coverage (#2725)
  • Fix zstd multi-frame decompression failure (#2717)
  • Fix KeyError in KafkaConsumer.committed() (#2710)
  • Fix VarInt/VarLong encoding; move tests to test/protocol/ (#2706)
  • Fix Fetcher._fetch_offsets_by_times retry handling (#2833)
  • Fixes to support integration testing with external KAFKA_URI (#2838)
  • Minor py2 fixes: consumer integration test; dont pip install python-snappy

2.3.0 (Nov 20, 2025)

2.3.x will be the last release branch with python2 support!

CLI

  • python -m cli interfaces for kafka.admin, kafka.consumer, kafka.producer (#2650)

Producer

  • KIP-654: Abort transaction with pending data with TransactionAbortedError (#2662)
  • KafkaProducer: Handle UnknownProducerIdError (#2663)
  • KIP-467: Augment ProduceResponse error messaging for specific culprit records (#2661)

Consumer

  • KIP-345: Consumer group static membership (#2625)
  • KIP-207: Add ListOffsetsRequest v5 / handle OffsetNotAvailableError (#2657)
  • Fetcher: Add missing argument in debug log (#2665)

AdminClient

  • KIP-430: Return Authorized Operations in Describe Responses (#2656)
  • Add send_request() and send_requests() to KafkaAdminClient (#2649)

Maintenance

  • Remove old/unused kafka.protocol.pickle (#2653)
  • Switch protocol code to getattr/setattr from dict (#2654)

... (truncated)

Changelog

Sourced from kafka-python's changelog.

2.3.2 (Jun 3, 2026) ###################

Fixes

  • kafka.conn: Improve error handling for sasl authenticate mechanisms
  • kafka.net: Validate SASL/SCRAM iterations (#3026)
  • KafkaProtocol: validate network frame size (backport of #3019)
  • Clear _callbacks/_errbacks list when future is_done to avoid reference cycles (#2891)

2.3.1 (Apr 9, 2026) ###################

Fixes

  • Fix TaggedFields value encoding; add test coverage (#2725)
  • Fix zstd multi-frame decompression failure (#2717)
  • Fix KeyError in KafkaConsumer.committed() (#2710)
  • Fix VarInt/VarLong encoding; move tests to test/protocol/ (#2706)
  • Fix Fetcher._fetch_offsets_by_times retry handling (#2833)
  • Fixes to support integration testing with external KAFKA_URI (#2838)
  • Minor py2 fixes: consumer integration test; dont pip install python-snappy

2.3.0 (Nov 20, 2025) ####################

CLI

  • python -m cli interfaces for kafka.admin, kafka.consumer, kafka.producer (#2650)

Producer

  • KIP-654: Abort transaction with pending data with TransactionAbortedError (#2662)
  • KafkaProducer: Handle UnknownProducerIdError (#2663)
  • KIP-467: Augment ProduceResponse error messaging for specific culprit records (#2661)
  • Add transactional_id to KafkaProducer Keyword Arguments docstring

Consumer

  • KIP-345: Consumer group static membership (#2625)
  • KIP-207: Add ListOffsetsRequest v5 / handle OffsetNotAvailableError (#2657)
  • Fetcher: Add missing argument in debug log (#2665)

AdminClient

  • KIP-430: Return Authorized Operations in Describe Responses (#2656)
  • Add send_request() and send_requests() to KafkaAdminClient (#2649)

... (truncated)

Commits
  • 054b570 Patch Release 2.3.2
  • 0efe08b kafka.conn: Improve error handling for sasl authenticate mechanisms
  • 74400d7 kafka.net: Validate SASL/SCRAM iterations (#3026)
  • 9f92d0f KafkaProtocol: validate network frame size (backport of #3019)
  • 79410e7 Clear _callbacks/_errbacks list when future is_done to avoid reference cycles...
  • 8e50f65 Enable manual workflow runs for Python Package
  • 62feaab Patch Release 2.3.1
  • 8037f81 Fixes to support integration testing with external KAFKA_URI (#2838)
  • 3479de9 python-snappy py3 only
  • 2c72167 Fix TaggedFields value encoding; add test coverage (#2725)
  • Additional commits viewable in compare view

Dependabot compatibility score

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)
    You can disable automated security fix PRs for this repo from the Security Alerts page.

Bumps [kafka-python](https://github.com/dpkp/kafka-python) from 2.0.6 to 2.3.2.
- [Release notes](https://github.com/dpkp/kafka-python/releases)
- [Changelog](https://github.com/dpkp/kafka-python/blob/2.3.2/docs/changelog.rst)
- [Commits](dpkp/kafka-python@2.0.6...2.3.2)

---
updated-dependencies:
- dependency-name: kafka-python
  dependency-version: 2.3.2
  dependency-type: direct:production
...

Signed-off-by: dependabot[bot] <support@github.com>
@dependabot dependabot Bot added dependencies Pull requests that update a dependency file python Pull requests that update python code labels Sep 1, 2026
@dependabot
dependabot Bot requested review from a team as code owners September 1, 2026 17:37
@dependabot dependabot Bot added dependencies Pull requests that update a dependency file python Pull requests that update python code labels Sep 1, 2026
@trusted-contributions-gcf trusted-contributions-gcf Bot added kokoro:force-run Add this label to force Kokoro to re-run the tests. owlbot:run Add this label to trigger the Owlbot post processor. labels Sep 1, 2026
@product-auto-label product-auto-label Bot added the samples Issues that are directly related to samples. label Sep 1, 2026
@kokoro-team kokoro-team removed the kokoro:force-run Add this label to force Kokoro to re-run the tests. label Sep 1, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

dependencies Pull requests that update a dependency file owlbot:run Add this label to trigger the Owlbot post processor. python Pull requests that update python code samples Issues that are directly related to samples.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant