Version 1.61.1 (2026-09-27)
- fix(protocol): add tagged field to alter configs config entries by @prestona in https://github.com/IBM/sarama/pull/3773
- fix(producer): number idempotent batches at flush by @dnwe in https://github.com/IBM/sarama/pull/3762
- fix: several correctness bugs in the txnmgr compared with Java by @dnwe in https://github.com/IBM/sarama/pull/3764
- fix(producer): keep resent batches muted on retry by @dnwe in https://github.com/IBM/sarama/pull/3765
- fix(producer): bump idempotent epoch once per batch by @dnwe in https://github.com/IBM/sarama/pull/3768
- fix(consumer): notify before releasing on abort by @dnwe in https://github.com/IBM/sarama/pull/3771
- fix(consumer): recheck closed after taking lock by @dnwe in https://github.com/IBM/sarama/pull/3772
- fix(client): metadata and broker lifecycle races by @dnwe in https://github.com/IBM/sarama/pull/3774
- fix: only abandon the current broker worker by @dnwe in https://github.com/IBM/sarama/pull/3777
- fix(consumer): fetch stable offsets for read_committed by @dnwe in https://github.com/IBM/sarama/pull/3779
- fix(txn): retry every retriable transaction error by @dnwe in https://github.com/IBM/sarama/pull/3783
- fix(txn): epoch bump follow-ups by @dnwe in https://github.com/IBM/sarama/pull/3766
- fix(txn): commit transactional offsets correctly by @dnwe in https://github.com/IBM/sarama/pull/3780
- fix(broker): enforce MaxOpenRequests before writing by @dnwe in https://github.com/IBM/sarama/pull/3782
- fix(consumer): keep member id across cooperative rejoin by @dnwe in https://github.com/IBM/sarama/pull/3763
- fix(consumer): cooperative rejoin and coordinator move by @dnwe in https://github.com/IBM/sarama/pull/3769
- fix(consumer): preferred read replica fallbacks by @dnwe in https://github.com/IBM/sarama/pull/3785
- fix(deps): update module github.com/klauspost/compress to v1.20.1 - autoclosed by @renovate[bot] in https://github.com/IBM/sarama/pull/3786
- chore(deps): update dependency golangci/golangci-lint to v2.14.0 by @renovate[bot] in https://github.com/IBM/sarama/pull/3776
- fix(deps): update module github.com/pierrec/lz4/v4 to v4.1.31 by @renovate[bot] in https://github.com/IBM/sarama/pull/3788
- docs(consumer): commit before revoke without autocommit by @dnwe in https://github.com/IBM/sarama/pull/3784
- test(functional): cover admin AlterConfig by @dnwe in https://github.com/IBM/sarama/pull/3775
- test(admin): answer FindCoordinator on both brokers by @dnwe in https://github.com/IBM/sarama/pull/3778
Full Changelog: https://github.com/IBM/sarama/compare/v1.61.0...v1.61.1
Version 1.61.0 (2026-09-22)
- feat(consumer): support cooperative rebalancing by @dnwe in https://github.com/IBM/sarama/pull/3696
- feat: support KIP-848 ConsumerGroupDescribe API by @shilohlee98 in https://github.com/IBM/sarama/pull/3748
- examples: add cooperative-sticky assignor to consumergroup by @dnwe in https://github.com/IBM/sarama/pull/3760
- fix(client): only deregister the broker registered under that ID by @hsdfat in https://github.com/IBM/sarama/pull/3752
- fix(consumer): stop roundrobin balancer looping on an unsubscribed topic by @lenamonj in https://github.com/IBM/sarama/pull/3740
- fix(producer): drain pending responses immediately once channel closes by @navi89mai in https://github.com/IBM/sarama/pull/3729
- fix: prevent race in asyncProducer retryHandler by @dloebl in https://github.com/IBM/sarama/pull/3733
- fix(protocol): return ErrUnsupportedVersion for absent broker API keys by @wxldonnaBJ in https://github.com/IBM/sarama/pull/3741
- chore(deps): update dependency golangci/golangci-lint to v2.13.2 by @renovate[bot] in https://github.com/IBM/sarama/pull/3732
- chore(deps): bump github.com/klauspost/compress from 1.19.2 to 1.20.0 by @dependabot[bot] in https://github.com/IBM/sarama/pull/3743
- chore(deps): bump github.com/pierrec/lz4/v4 from 4.1.29 to 4.1.30 by @dependabot[bot] in https://github.com/IBM/sarama/pull/3751
- chore(deps): update dependency vearutop/teststat to v0.1.29 by @renovate[bot] in https://github.com/IBM/sarama/pull/3730
- chore(deps): bump the golang-x group across 1 directory with 3 updates by @dependabot[bot] in https://github.com/IBM/sarama/pull/3749
- chore(deps): update docker/bake-action action to v7.4.0 - autoclosed by @renovate[bot] in https://github.com/IBM/sarama/pull/3756
- chore(deps): update docker/setup-buildx-action action to v4.4.1 by @renovate[bot] in https://github.com/IBM/sarama/pull/3757
- fix(test): capture logs without replacing the global Logger by @official-burak in https://github.com/IBM/sarama/pull/3737
- test(functional): cover cooperative Java interoperability by @dnwe in https://github.com/IBM/sarama/pull/3754
- docs: clarify producer batching configuration by @krvladislav in https://github.com/IBM/sarama/pull/3712
- @shilohlee98 made their first contribution in https://github.com/IBM/sarama/pull/3748
- @hsdfat made their first contribution in https://github.com/IBM/sarama/pull/3752
- @lenamonj made their first contribution in https://github.com/IBM/sarama/pull/3740
- @navi89mai made their first contribution in https://github.com/IBM/sarama/pull/3729
- @krvladislav made their first contribution in https://github.com/IBM/sarama/pull/3712
- @dloebl made their first contribution in https://github.com/IBM/sarama/pull/3733
- @official-burak made their first contribution in https://github.com/IBM/sarama/pull/3737
- @wxldonnaBJ made their first contribution in https://github.com/IBM/sarama/pull/3741
Full Changelog: https://github.com/IBM/sarama/compare/v1.60.2...v1.61.0
Version 1.60.2 (2026-08-24)
- fix: correct JoinGroup v8 selection threshold to V3_2_0_0 by @mpicque in https://github.com/IBM/sarama/pull/3722
- chore(deps): bump github.com/klauspost/compress from 1.19.1 to 1.19.2 by @dependabot[bot] in https://github.com/IBM/sarama/pull/3706
- chore(deps): bump github.com/pierrec/lz4/v4 from 4.1.27 to 4.1.28 by @dependabot[bot] in https://github.com/IBM/sarama/pull/3705
- chore(deps): update module golang.org/x/crypto to v0.55.0 by @renovate[bot] in https://github.com/IBM/sarama/pull/3707
- fix(deps): update module github.com/stretchr/testify to v1.12.0 by @renovate[bot] in https://github.com/IBM/sarama/pull/3713
- fix(deps): update module github.com/stretchr/testify to v1.12.1 by @renovate[bot] in https://github.com/IBM/sarama/pull/3719
- fix(deps): update module github.com/pierrec/lz4/v4 to v4.1.29 by @renovate[bot] in https://github.com/IBM/sarama/pull/3718
- fix(deps): update module golang.org/x/net to v0.58.0 by @renovate[bot] in https://github.com/IBM/sarama/pull/3708
- chore(deps): update docker/setup-buildx-action action to v4.3.0 by @renovate[bot] in https://github.com/IBM/sarama/pull/3726
- chore(ci): update linters for Go 1.27 by @dnwe in https://github.com/IBM/sarama/pull/3725
- @mpicque made their first contribution in https://github.com/IBM/sarama/pull/3722
Full Changelog: https://github.com/IBM/sarama/compare/v1.60.1...v1.60.2
Version 1.60.1 (2026-07-29)
- feat(consumer): add rebalance protocol plumbing by @dnwe in https://github.com/IBM/sarama/pull/3670
- feat: add Kafka versions 4.1.2, 4.2.1 and 4.3.1 by @dnwe in https://github.com/IBM/sarama/pull/3675
- feat: raise default Kafka version to 2.8.0 by @dnwe in https://github.com/IBM/sarama/pull/3676
- feat(consumer): add cooperative sticky assignor by @dnwe in https://github.com/IBM/sarama/pull/3671
- feat: add TransactionClusterAdmin for KIP-664 detection APIs by @adrian-januzi in https://github.com/IBM/sarama/pull/3669
- feat(offset): commit revoked partitions on cooperative rebalance by @dnwe in https://github.com/IBM/sarama/pull/3688
- fix(consumer): preserve pauses across reassignment by @dnwe in https://github.com/IBM/sarama/pull/3681
- fix(producer): wake stranded brokerProducer when partition unmutes by @dnwe in https://github.com/IBM/sarama/pull/3692
- fix(deps): update module github.com/klauspost/compress to v1.19.1 by @renovate[bot] in https://github.com/IBM/sarama/pull/3649
- chore(deps): update ossf/scorecard-action action to v2.4.4 by @renovate[bot] in https://github.com/IBM/sarama/pull/3683
- refactor(consumer): separate join and sync round by @dnwe in https://github.com/IBM/sarama/pull/3680
- @adrian-januzi made their first contribution in https://github.com/IBM/sarama/pull/3669
Full Changelog: https://github.com/IBM/sarama/compare/v1.60.0...v1.60.1
Version 1.60.0 (2026-07-13)
- feat: support Metadata V11 by @dnwe in https://github.com/IBM/sarama/pull/3636
- feat: support Produce V10 by @dnwe in https://github.com/IBM/sarama/pull/3637
- feat: support DescribeProducers v0 by @dnwe in https://github.com/IBM/sarama/pull/3659
- feat: support DescribeTransactions v0 by @dnwe in https://github.com/IBM/sarama/pull/3661
- feat: support int64 arrays in flexible protocol by @dnwe in https://github.com/IBM/sarama/pull/3662
- feat: support ListTransactions v0 and v1 by @dnwe in https://github.com/IBM/sarama/pull/3663
- feat: more flexible protocols for kafka28 parity by @dnwe in https://github.com/IBM/sarama/pull/3664
- feat: support KIP-516 topic ids by @dnwe in https://github.com/IBM/sarama/pull/3666
- fix: correct fetch v12 tagged struct encoding by @dnwe in https://github.com/IBM/sarama/pull/3638
- fix: map new metadata request v8 to kafka 2.3.0 by @fereidani in https://github.com/IBM/sarama/pull/3642
- fix: handle zstd encoder and decoder construction errors by @fereidani in https://github.com/IBM/sarama/pull/3643
- fix: release retry mute on shutdown handoff by @dnwe in https://github.com/IBM/sarama/pull/3645
- fix: order non-idempotent connection retries by @dnwe in https://github.com/IBM/sarama/pull/3644
- chore(deps): bump the golang-x group across 1 directory with 3 updates by @dependabot[bot] in https://github.com/IBM/sarama/pull/3660
- chore(deps): update docker/setup-buildx-action action to v4.2.0 by @renovate[bot] in https://github.com/IBM/sarama/pull/3658
- chore(deps): update docker/bake-action action to v7.3.0 by @renovate[bot] in https://github.com/IBM/sarama/pull/3652
- chore(deps): bump github.com/klauspost/compress from 1.18.6 to 1.19.0 by @dependabot[bot] in https://github.com/IBM/sarama/pull/3651
- chore(deps): update golangci/golangci-lint-action action to v9.3.0 by @renovate[bot] in https://github.com/IBM/sarama/pull/3648
- fix: correct typos in comments and godoc by @maxtaran2010 in https://github.com/IBM/sarama/pull/3656
- @fereidani made their first contribution in https://github.com/IBM/sarama/pull/3642
- @maxtaran2010 made their first contribution in https://github.com/IBM/sarama/pull/3656
Full Changelog: https://github.com/IBM/sarama/compare/v1.50.3...v1.60.0
Version 1.50.3 (2026-06-15)
- feat: support Fetch v12 by @dnwe in https://github.com/IBM/sarama/pull/3609
- feat: support CreateTopics v6 by @dnwe in https://github.com/IBM/sarama/pull/3622
- feat: support DeleteTopics v5 by @dnwe in https://github.com/IBM/sarama/pull/3624
- feat: support AddPartitionsToTxn v3 by @hindessm in https://github.com/IBM/sarama/pull/3625
- feat: support Produce v9 by @dnwe in https://github.com/IBM/sarama/pull/3629
- feat: support CreatePartitions v3 by @dnwe in https://github.com/IBM/sarama/pull/3631
- feat: expose broker features from ApiVersions v3 by @dnwe in https://github.com/IBM/sarama/pull/3633
- feat: support UpdateFeatures by @dnwe in https://github.com/IBM/sarama/pull/3632
- feat: add OnAssignmentBalanceStrategy, the onAssignment half of the assignor contract by @lizthegrey in https://github.com/IBM/sarama/pull/3627
- feat: support ApiVersions V4 and discover upgradable features in test by @dnwe in https://github.com/IBM/sarama/pull/3634
- fix: avoid makeslice "len out of range" panics on invalid response by @hindessm in https://github.com/IBM/sarama/pull/3612
- fix: avoid makeslice panic in request decode too by @dnwe in https://github.com/IBM/sarama/pull/3613
- fix(test): wait for leaders after topic create by @dnwe in https://github.com/IBM/sarama/pull/3623
- fix(consumer): don't panic on requeue after unref by @dnwe in https://github.com/IBM/sarama/pull/3630
- chore(deps): update golang-x to v0.53.0 by @renovate[bot] in https://github.com/IBM/sarama/pull/3618
- fix(deps): update module golang.org/x/sys to v0.46.0 - autoclosed by @renovate[bot] in https://github.com/IBM/sarama/pull/3617
- fix(deps): update module golang.org/x/sync to v0.21.0 by @renovate[bot] in https://github.com/IBM/sarama/pull/3616
- fix(deps): update module golang.org/x/net to v0.56.0 by @renovate[bot] in https://github.com/IBM/sarama/pull/3626
- chore: update default Kafka version to 2.6 by @dnwe in https://github.com/IBM/sarama/pull/3608
- chore: more protocol version placeholders by @hindessm in https://github.com/IBM/sarama/pull/3610
- chore: extend fuzz testing to more types by @dnwe in https://github.com/IBM/sarama/pull/3614
- chore: clean up Int32 array encode/decode by @hindessm in https://github.com/IBM/sarama/pull/3619
- chore: apply Go's modernize fixes by @dnwe in https://github.com/IBM/sarama/pull/3621
Full Changelog: https://github.com/IBM/sarama/compare/v1.50.2...v1.50.3
Version 1.50.2 (2026-06-05)
- feat(consumer): add support for SyncGroupRequest/Response v5 (KIP-559) by @dnwe in https://github.com/IBM/sarama/pull/3591
- feat(txn): add protocol support for TxnOffsetCommit v3 by @dnwe in https://github.com/IBM/sarama/pull/3592
- feat(txn): support consumer group metadata in TxnOffsetCommit v3 by @dnwe in https://github.com/IBM/sarama/pull/3593
- feat(admin): add protocol support for DeleteRecords v2 (KIP-482) by @dnwe in https://github.com/IBM/sarama/pull/3594
- feat(protocol): add support for DescribeConfigs v3 and v4 by @dnwe in https://github.com/IBM/sarama/pull/3596
- feat(admin): add DescribeConfigs for multiple resources by @dnwe in https://github.com/IBM/sarama/pull/3600
- feat(consumer): option to cap decompressed batch size by @dnwe in https://github.com/IBM/sarama/pull/3604
- fix(admin): retry ACL and SCRAM ops on stale controller by @dnwe in https://github.com/IBM/sarama/pull/3598
- fix(deps): update module github.com/pierrec/lz4/v4 to v4.1.27 by @renovate[bot] in https://github.com/IBM/sarama/pull/3597
Full Changelog: https://github.com/IBM/sarama/compare/v1.50.1...v1.50.2
Version 1.50.1 (2026-05-27)
- fix: correct requiredVersion for V8 JoinGroup and add protocol version placeholders by @dnwe in https://github.com/IBM/sarama/pull/3585
Full Changelog: https://github.com/IBM/sarama/compare/v1.50.0...v1.50.1
Version 1.50.0 (2026-05-27)
- feat: add Java-compatible murmur2 partitioner by @dnwe in https://github.com/IBM/sarama/pull/3567
- feat(protocol): support LeaveGroupRequest/Response v5 (KIP-800) by @dnwe in https://github.com/IBM/sarama/pull/3576
- feat(protocol): support JoinGroupRequest/Response v8 (KIP-800) by @dnwe in https://github.com/IBM/sarama/pull/3577
- feat(consumer_group): set cancellation cause on session context by @prakhar7651 in https://github.com/IBM/sarama/pull/3575
- feat(consumer_group): send KIP-800 reason on JoinGroup and LeaveGroup by @dnwe in https://github.com/IBM/sarama/pull/3584
- feat: add Kafka 4.3.0 version placeholder by @dnwe in https://github.com/IBM/sarama/pull/3587
- feat(admin): support OffsetFetchRequest v8 by @dnwe in https://github.com/IBM/sarama/pull/3565
- fix(client): don't log ErrNoTopicsToUpdateMetadata every tick by @dnwe in https://github.com/IBM/sarama/pull/3566
- fix(broker): snapshot fetch meters before deferred Mark by @dnwe in https://github.com/IBM/sarama/pull/3563
- fix: prevent len out of range panic on 32bit architectures by @gibmat in https://github.com/IBM/sarama/pull/3579
- fix(offset): retry fetchInitialOffset on top-level coordinator errors by @dnwe in https://github.com/IBM/sarama/pull/3574
- chore(deps): update docker/bake-action action to v7.2.0 by @renovate[bot] in https://github.com/IBM/sarama/pull/3568
- fix(deps): update module golang.org/x/sys to v0.45.0 by @renovate[bot] in https://github.com/IBM/sarama/pull/3570
- chore(deps): update golangci/golangci-lint-action action to v9.2.1 by @renovate[bot] in https://github.com/IBM/sarama/pull/3571
- chore(deps): update module golang.org/x/crypto to v0.52.0 by @renovate[bot] in https://github.com/IBM/sarama/pull/3572
- fix(deps): update module golang.org/x/net to v0.55.0 by @renovate[bot] in https://github.com/IBM/sarama/pull/3573
- chore(deps): update docker/setup-buildx-action action to v4.1.0 by @renovate[bot] in https://github.com/IBM/sarama/pull/3578
- refactor: replace eapache/queue with generic ring buffer by @dnwe in https://github.com/IBM/sarama/pull/3560
- test(fvt): use a per-message timeout in follower failover test by @dnwe in https://github.com/IBM/sarama/pull/3562
- @gibmat made their first contribution in https://github.com/IBM/sarama/pull/3579
- @prakhar7651 made their first contribution in https://github.com/IBM/sarama/pull/3575
Full Changelog: https://github.com/IBM/sarama/compare/v1.49.0...v1.50.0
Version 1.49.0 (2026-05-18)
- fix(consumer): decouple FetchRequest.MaxBytes from MaxResponseSize by @dnwe in https://github.com/IBM/sarama/pull/3538
- feat(consumer): warn on sustained partition retries by @dnwe in https://github.com/IBM/sarama/pull/3535
- feat(producer): add Produce v8 request/response support by @dnwe in https://github.com/IBM/sarama/pull/3540
- feat(consumer): cap partition consumer retries by @dnwe in https://github.com/IBM/sarama/pull/3539
- feat: support FindCoordinator V3 protocol by @hindessm in https://github.com/IBM/sarama/pull/3544
- feat: support describe acls v2 by @hindessm in https://github.com/IBM/sarama/pull/3548
- feat: support create acls v2 by @hindessm in https://github.com/IBM/sarama/pull/3549
- feat: support delete acls v2 by @hindessm in https://github.com/IBM/sarama/pull/3550
- feat: support sasl authenticate v2 by @hindessm in https://github.com/IBM/sarama/pull/3551
- feat: support create partitions v2 by @hindessm in https://github.com/IBM/sarama/pull/3554
- feat: support join group v7 by @hindessm in https://github.com/IBM/sarama/pull/3555
- fix: flexible decoder out-of-bounds panic by @hindessm in https://github.com/IBM/sarama/pull/3543
- fix(consumer): size partial-batch retry correctly by @dnwe in https://github.com/IBM/sarama/pull/3541
- feat(consumer): add OffsetCommit v8 request/response support by @dnwe in https://github.com/IBM/sarama/pull/3545
- fix: decode nullable ACL describe error messages by @dnwe in https://github.com/IBM/sarama/pull/3552
- fix(consumer): lease preferred read replicas by @dnwe in https://github.com/IBM/sarama/pull/3553
- fix(producer): honour Retry.Backoff in idempotent retryBatch by @dnwe in https://github.com/IBM/sarama/pull/3557
- chore: better bounds checking by @hindessm in https://github.com/IBM/sarama/pull/3546
- chore: bump deps in ./examples tree by @dnwe in https://github.com/IBM/sarama/pull/3558
- docs: add AlterPartitionReassignments example and functional test by @dnwe in https://github.com/IBM/sarama/pull/3556
Full Changelog: https://github.com/IBM/sarama/compare/v1.48.2...v1.49.0