Bump kafka-python from 2.0.2 to 2.2.2

[dependabot]

Bumps kafka-python from 2.0.2 to 2.2.2.

Release notes

Sourced from kafka-python's releases.

2.2.1 (Apr 29, 2025)

Fixes

• Always try ApiVersionsRequest v0, even on broker disconnect (#2603)
• Fix SubscriptionState AttributeError in KafkaConsumer (#2599)

Documentation

• Add transactional examples to docs

2.2.0 (Apr 28, 2025)

KafkaProducer

• KIP-98: Add idempotent producer support (#2569)
• KIP-98: Transactional Producer (#2587)
• KIP-98: Add offsets support to transactional KafkaProducer (#2590)
• Prefix producer logs w/ client id and transactional id (#2591)
• KAFKA-5429: Ignore produce response if batch was previously aborted
• KIP-91: KafkaProducer delivery_timeout_ms
• Default retries -> infinite
• Expand KafkaProducer docstring w/ idempotent and transactional notes
• RecordAccumulator: Use helper method to get/set _tp_locks; get dq with lock in reenqueue()

KafkaConsumer

• KIP-98: Add Consumer support for READ_COMMITTED (#2582)
• KIP-394: handle MEMBER_ID_REQUIRED error w/ second join group request (#2598)
• KAFKA-5078: Defer fetch record exception if iterator has already moved across a valid record
• KAFKA-5075: Defer consumer fetcher exception if fetch position has already increased
• KAFKA-4937: Batch offset fetches in the Consumer
• KAFKA-4547: Avoid resetting paused partitions to committed offsets
• KAFKA-6397: Consumer should not block setting positions of unavailable partitions (#2593)

Potentially Breaking Changes (internal)

• Rename CorruptRecordException -> CorruptRecordError
• Rename Coordinator errors to generic not group (#2585)
• Rename ClusterMetadata.add_group_coordinator -> add_coordinator + support txn type
• Use SaslAuthenticationFailedError in kafka.conn connection failure; Drop unused AuthenticationFailedError
• Remove old/unused errors; reorder; KafkaTimeout -> retriable
• Drop log_start_offset from producer RecordMetadata

Internal

• MemoryRecords iterator; MemoryRecordsBuilder records() helper
• Convert DefaultRecordsBuilder.size_in_bytes to classmethod

Fixes

... (truncated)

Changelog

Sourced from kafka-python's changelog.

2.2.2 (Apr 30, 2025) ####################

Fixes

• Fix lint errors

2.2.1 (Apr 29, 2025) ####################

Fixes

• Always try ApiVersionsRequest v0, even on broker disconnect (#2603)
• Fix SubscriptionState AttributeError in KafkaConsumer (#2599)

Documentation

• Add transactional examples to docs

2.2.0 (Apr 28, 2025) ####################

KafkaProducer

• KIP-98: Add idempotent producer support (#2569)
• KIP-98: Transactional Producer (#2587)
• KIP-98: Add offsets support to transactional KafkaProducer (#2590)
• Prefix producer logs w/ client id and transactional id (#2591)
• KAFKA-5429: Ignore produce response if batch was previously aborted
• KIP-91: KafkaProducer delivery_timeout_ms
• Default retries -> infinite
• Expand KafkaProducer docstring w/ idempotent and transactional notes
• RecordAccumulator: Use helper method to get/set _tp_locks; get dq with lock in reenqueue()

KafkaConsumer

• KIP-98: Add Consumer support for READ_COMMITTED (#2582)
• KIP-394: handle MEMBER_ID_REQUIRED error w/ second join group request (#2598)
• KAFKA-5078: Defer fetch record exception if iterator has already moved across a valid record
• KAFKA-5075: Defer consumer fetcher exception if fetch position has already increased
• KAFKA-4937: Batch offset fetches in the Consumer
• KAFKA-4547: Avoid resetting paused partitions to committed offsets
• KAFKA-6397: Consumer should not block setting positions of unavailable partitions (#2593)

Potentially Breaking Changes (internal)

• Rename CorruptRecordException -> CorruptRecordError
• Rename Coordinator errors to generic not group (#2585)

... (truncated)

Commits

• 3d31c14 Patch Release 2.2.2
• 998efc2 Fix lint errors
• cb2868f Bump version for development
• 8c39733 Patch Release 2.2.1
• 842f398 Always try ApiVersionsRequest v0, even on broker disconnect (#2603)
• c35c161 Fix SubscriptionState AttributeError in KafkaConsumer (#2599)
• 284c8a7 Add transactional examples to docs
• 0f481e0 Bump version for development
• 603e10e Release 2.2.0
• fb04626 KIP-394: handle MEMBER_ID_REQUIRED error w/ second join group request (#2598)
• 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 merge will merge this PR after your CI passes on it
• @dependabot squash and merge will squash and merge this PR after your CI passes on it
• @dependabot cancel merge will cancel a previously requested merge and block automerging
• @dependabot reopen will reopen this PR if it is closed
• @dependabot close will close this PR and stop Dependabot recreating it. You can achieve the same result by closing it manually
• @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)

[dependabot]

Superseded by #511.