Skip to content

Conversation

@dependabot
Copy link
Contributor

@dependabot dependabot bot commented on behalf of github Mar 18, 2025

Bumps kafka-python from 2.0.6 to 2.1.2.

Release notes

Sourced from kafka-python's releases.

2.1.2 (Mar 17, 2025)

Fixes

  • Simplify consumer.poll send fetches logic
  • Fix crc validation in consumer / fetcher
  • Lazy _unpack_records in PartitionRecords to fix premature fetch offset advance in consumer.poll() (#2555)
  • Debug log fetch records return; separate offsets update log
  • Fix Fetcher retriable error handling (#2554)
  • Use six.add_metaclass for py2/py3 compatible abc (#2551)

Improvements

  • Add FetchMetrics class; move topic_fetch_metrics inside aggregator
  • DefaultRecordsBatchBuilder: support empty batch
  • MemoryRecordsBuilder: support arbitrary offset, skipping offsets
  • Add record.validate_crc() for v0/v1 crc checks
  • Remove fetcher message_generator / iterator interface
  • Add size_in_bytes to ABCRecordBatch and implement for Legacy and Default
  • Add magic property to ABCRecord and implement for LegacyRecord

2.1.1 (Mar 16, 2025)

Fixes

  • Fix packaging of 2.1.0 in Fedora: testing requires "pytest-timeout". (#2550)
  • Improve connection error handling when try_api_versions_check fails all attempts (#2548)
  • Add lock synchronization to Future success/failure (#2549)
  • Fix StickyPartitionAssignor encode

2.1.0 (Mar 15, 2025)

Support Kafka Broker 2.1 API Baseline

  • Add baseline leader_epoch support for ListOffsets v4 / FetchRequest v10 (#2511)
  • Support OffsetFetch v5 / OffsetCommit v6 (2.1 baseline) (#2505)
  • Support 2.1 baseline consumer group apis (#2503)
  • Support FindCoordinatorRequest v2 in consumer and admin client (#2502)
  • Support ListOffsets v3 in consumer (#2501)
  • Support Fetch Request/Response v6 in consumer (#2500)
  • Add support for Metadata Request/Response v7 (#2497)
  • Implement Incremental Fetch Sessions / KIP-227 (#2508)
  • Implement client-side connection throttling / KIP-219 (#2510)
  • Add KafkaClient.api_version(operation) for best available from api_versions (#2495)

Consumer

  • Timeout coordinator poll / ensure_coordinator_ready / ensure_active_group (#2526)
  • Add optional timeout_ms kwarg to remaining consumer/coordinator methods (#2544)
  • Check for coordinator.poll failure in KafkaConsumer

... (truncated)

Changelog

Sourced from kafka-python's changelog.

2.1.2 (Mar 17, 2025) ####################

Fixes

  • Simplify consumer.poll send fetches logic
  • Fix crc validation in consumer / fetcher
  • Lazy _unpack_records in PartitionRecords to fix premature fetch offset advance in consumer.poll() (#2555)
  • Debug log fetch records return; separate offsets update log
  • Fix Fetcher retriable error handling (#2554)
  • Use six.add_metaclass for py2/py3 compatible abc (#2551)

Improvements

  • Add FetchMetrics class; move topic_fetch_metrics inside aggregator
  • DefaultRecordsBatchBuilder: support empty batch
  • MemoryRecordsBuilder: support arbitrary offset, skipping offsets
  • Add record.validate_crc() for v0/v1 crc checks
  • Remove fetcher message_generator / iterator interface
  • Add size_in_bytes to ABCRecordBatch and implement for Legacy and Default
  • Add magic property to ABCRecord and implement for LegacyRecord

2.1.1 (Mar 16, 2025) ####################

Fixes

  • Fix packaging of 2.1.0 in Fedora: testing requires "pytest-timeout". (#2550)
  • Improve connection error handling when try_api_versions_check fails all attempts (#2548)
  • Add lock synchronization to Future success/failure (#2549)
  • Fix StickyPartitionAssignor encode

2.1.0 (Mar 15, 2025) ####################

Support Kafka Broker 2.1 API Baseline

  • Add baseline leader_epoch support for ListOffsets v4 / FetchRequest v10 (#2511)
  • Support OffsetFetch v5 / OffsetCommit v6 (2.1 baseline) (#2505)
  • Support 2.1 baseline consumer group apis (#2503)
  • Support FindCoordinatorRequest v2 in consumer and admin client (#2502)
  • Support ListOffsets v3 in consumer (#2501)
  • Support Fetch Request/Response v6 in consumer (#2500)
  • Add support for Metadata Request/Response v7 (#2497)
  • Implement Incremental Fetch Sessions / KIP-227 (#2508)
  • Implement client-side connection throttling / KIP-219 (#2510)
  • Add KafkaClient.api_version(operation) for best available from api_versions (#2495)

... (truncated)

Commits
  • bea9d46 Patch Release 2.1.2
  • 14643ca simplify consumer.poll send fetches logic
  • a441ef3 Validate crcs in fetcher
  • a0b96ec Lazy _unpack_records in PartitionRecords
  • 36f7a0c Debug log fetch records return; separate offsets update log
  • cab08df revert last_offset_from_record_batch
  • b75248e Add FetchMetrics class; move topic_fetch_metrics inside aggregator
  • 8be2568 DefaultRecordsBatchBuilder: support empty batch
  • 585a111 MemoryRecordsBuilder: support arbitrary offset, skipping offsets
  • c763939 Add record.validate_crc() for v0/v1 crc checks
  • 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 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)

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

---
updated-dependencies:
- dependency-name: kafka-python
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>
@dependabot @github
Copy link
Contributor Author

dependabot bot commented on behalf of github Mar 26, 2025

Superseded by #487.

@dependabot dependabot bot closed this Mar 26, 2025
@dependabot dependabot bot deleted the dependabot/pip/kafka-python-2.1.2 branch March 26, 2025 10:59
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant