Version 1.60.1 (2026-07-29)

What's Changed

🎉 New Features / Improvements

• feat(consumer): add rebalance protocol plumbing by @dnwe in #3670
• feat: add Kafka versions 4.1.2, 4.2.1 and 4.3.1 by @dnwe in #3675
• feat: raise default Kafka version to 2.8.0 by @dnwe in #3676
• feat(consumer): add cooperative sticky assignor by @dnwe in #3671
• feat: add TransactionClusterAdmin for KIP-664 detection APIs by @adrian-januzi in #3669
• feat(offset): commit revoked partitions on cooperative rebalance by @dnwe in #3688

🐛 Fixes

• fix(consumer): preserve pauses across reassignment by @dnwe in #3681
• fix(producer): wake stranded brokerProducer when partition unmutes by @dnwe in #3692

📦 Dependency updates

• fix(deps): update module github.com/klauspost/compress to v1.19.1 by @renovate[bot] in #3649
• chore(deps): update ossf/scorecard-action action to v2.4.4 by @renovate[bot] in #3683

🔧 Maintenance

• refactor(consumer): separate join and sync round by @dnwe in #3680

New Contributors

• @adrian-januzi made their first contribution in #3669

Full Changelog: v1.60.0...v1.60.1