Version 1.44.0 (2024-12-27)

What's Changed

🎉 New Features / Improvements

• feat: update go directive to 1.20 by @mauri870 in #2933
• feat(producer): add retry buffer tuning option to prevent OOM by @wanwenli in #3026
• feat(admin): implement leader election api by @chengjoey in #3030

🐛 Fixes

• fix: log SASL connection and handshake errors by @pierDipi in #2995

📦 Dependency updates

• chore(deps): bump the golang-org-x group across 1 directory with 2 updates by @dependabot in #3010
• chore(deps): bump golang.org/x/crypto from 0.28.0 to 0.31.0 in the go_modules group by @dependabot in #3041
• chore(deps): bump the golang-org-x group across 1 directory with 2 updates by @dependabot in #3040
• chore(deps): bump github.com/pierrec/lz4/v4 from 4.1.21 to 4.1.22 by @dependabot in #3038
• chore(deps): bump the go_modules group across 2 directories with 1 update by @dependabot in #3035
• chore(deps): bump golang.org/x/crypto from 0.22.0 to 0.31.0 in /examples/consumergroup in the go_modules group by @dependabot in #3033
• chore(deps): bump golang.org/x/crypto from 0.22.0 to 0.31.0 in /examples/txn_producer in the go_modules group by @dependabot in #3034
• chore(deps): bump golang.org/x/crypto from 0.22.0 to 0.31.0 in /examples/interceptors in the go_modules group by @dependabot in #3032
• chore(deps): bump golang.org/x/crypto from 0.22.0 to 0.31.0 in /examples/exactly_once in the go_modules group by @dependabot in #3031
• chore(deps): bump github.com/stretchr/testify from 1.9.0 to 1.10.0 by @dependabot in #3020

🔧 Maintenance

• chore: add newer kafka versions and bump Go in CI by @dnwe in #2969
• fix(lint): resolve IDENTICAL_BRANCHES issue in broker by @frzifus in #2992
• chore: add version consts for 3.8.1+3.9.0 by @dnwe in #3011
• fix(client): refactor duplicated replica+partition logic by @Trinoooo in #2925
• chore(deps): bump golang.org/x/net to v0.33.0 by @dnwe in #3044

New Contributors

• @mauri870 made their first contribution in #2933
• @frzifus made their first contribution in #2992
• @pierDipi made their first contribution in #2995
• @wanwenli made their first contribution in #3026
• @Trinoooo made their first contribution in #2925
• @chengjoey made their first contribution in #3030

Full Changelog: v1.43.3...v1.44.0

Version 1.43.3 (2024-08-12)

What's Changed

🐛 Fixes

• fix: declare assignor variable for examples & clean up log format by @kumakichi in #2909
• fix(consumer): maintain ordering of offset commit requests by @prestona in #2947
• fix(producer): treat ErrKafkaStorageError as retriable by @richardartoul in #2939

📦 Dependency updates

• chore(deps): bump the golang-org-x group across 1 directory with 2 updates by @dependabot in #2956
• chore(deps): bump github.com/eapache/go-resiliency from 1.6.0 to 1.7.0 by @dependabot in #2944
• chore(deps): bump github.com/klauspost/compress from 1.17.8 to 1.17.9 by @dependabot in #2926

🔧 Maintenance

• fix(ci): correct docker-compose install by @dnwe in #2954

📝 Documentation

• fix(doc): correct JVM's config name corresponding to MaxWaitTime by @abhipranay in #2893

New Contributors

• @abhipranay made their first contribution in #2893
• @kumakichi made their first contribution in #2909
• @richardartoul made their first contribution in #2939

Full Changelog: v1.43.2...v1.43.3

Version 1.43.2 (2024-04-25)

What's Changed

🐛 Fixes

• chore(ci): add 32-bit alignment check by @dnwe in #2874

📦 Dependency updates

• chore(deps): bump golang.org/x/net from 0.21.0 to 0.23.0 by @dependabot in #2866
• chore(deps): bump the golang-org-x group with 2 updates by @dependabot in #2853
• chore(deps): bump github.com/klauspost/compress from 1.17.7 to 1.17.8 by @dependabot in #2857
• chore(deps): bump golang.org/x/net from 0.21.0 to 0.23.0 in /examples/txn_producer in the go_modules group by @dependabot in #2865
• chore(deps): bump golang.org/x/net from 0.21.0 to 0.23.0 in /examples/consumergroup in the go_modules group by @dependabot in #2867
• chore(deps): bump golang.org/x/net from 0.21.0 to 0.23.0 in /examples/exactly_once in the go_modules group by @dependabot in #2868
• chore(deps): bump golang.org/x/net from 0.22.0 to 0.23.0 in /examples/interceptors in the go_modules group by @dependabot in #2869

Full Changelog: v1.43.1...v1.43.2

Version 1.43.1 (2024-03-27)

What's Changed

🐛 Fixes

• fix: message.max.bytes should default to 1048576 not 1 MB by @puellanivis in #2804
• fix: add locking around broker throttle timer to prevent race condition by @chengsha in #2826

📦 Dependency updates

• chore(deps): bump go.opentelemetry.io/otel/sdk from 1.23.1 to 1.24.0 in /examples/interceptors by @dependabot in #2816
• chore(deps): bump the golang-org-x group with 1 update by @dependabot in #2825
• chore(deps): bump github.com/stretchr/testify from 1.8.4 to 1.9.0 by @dependabot in #2822
• chore(deps): bump go.opentelemetry.io/otel/exporters/stdout/stdoutmetric from 1.23.1 to 1.24.0 in /examples/interceptors by @dependabot in #2815

New Contributors

• @chengsha made their first contribution in #2826

Full Changelog: v1.43.0...v1.43.1

Version 1.43.0 (2024-02-22)

Note

The go.mod directive has been bumped to 1.19 as the minimum version of Go required for the module. This was necessary to continue to receive updates from some of the third party dependencies that Sarama makes use of for compression.

What's Changed

🎉 New Features / Improvements

• feat: update go directive to 1.19 by @dnwe in #2795
• feat: add BuildSpnFunc to GSSAPIConfig for allow custom spn by @fooofei in #2807

🐛 Fixes

• Use %v formatting words and remove unnecessary newline by @puellanivis in #2802

📦 Dependency updates

• chore(deps): bump github.com/klauspost/compress from 1.16.7 to 1.17.6 by @dependabot in #2784
• chore(deps): bump github.com/eapache/go-resiliency from 1.5.0 to 1.6.0 by @dependabot in #2810
• chore(deps): bump github.com/klauspost/compress from 1.17.6 to 1.17.7 by @dependabot in #2811

🔧 Maintenance

• chore(doc): add v1.42.2 to CHANGELOG.md by @dnwe in #2796

New Contributors

• @puellanivis made their first contribution in #2802
• @fooofei made their first contribution in #2807

Full Changelog: v1.42.2...v1.43.0

Version 1.42.2 (2024-02-09)

What's Changed

Note

The go.mod directive has been bumped to 1.18 as the minimum version of Go required for the module. This was necessary to continue to receive updates from some of the third party dependencies that Sarama makes use of for compression.

🎉 New Features / Improvements

• feat: update go directive to 1.18 by @dnwe in #2713
• feat: return KError instead of errors in AlterConfigs and DescribeConfig by @zhuliquan in #2472

🐛 Fixes

• fix: don't waste time for backoff on member id required error by @lzakharov in #2759
• fix: prevent ConsumerGroup.Close infinitely locking by @maqdev in #2717

📦 Dependency updates

• chore(deps): bump golang.org/x/net from 0.17.0 to 0.18.0 by @dependabot in #2716
• chore(deps): bump golang.org/x/sync to v0.5.0 by @dependabot in #2718
• chore(deps): bump github.com/pierrec/lz4/v4 from 4.1.18 to 4.1.19 by @dependabot in #2739
• chore(deps): bump golang.org/x/crypto from 0.15.0 to 0.17.0 by @dependabot in #2748
• chore(deps): bump the golang-org-x group with 1 update by @dependabot in #2734
• chore(deps): bump the golang-org-x group with 2 updates by @dependabot in #2764
• chore(deps): bump github.com/pierrec/lz4/v4 from 4.1.19 to 4.1.21 by @dependabot in #2763
• chore(deps): bump golang.org/x/crypto from 0.15.0 to 0.17.0 in /examples/exactly_once by @dependabot in #2749
• chore(deps): bump golang.org/x/crypto from 0.15.0 to 0.17.0 in /examples/consumergroup by @dependabot in #2750
• chore(deps): bump golang.org/x/crypto from 0.15.0 to 0.17.0 in /examples/sasl_scram_client by @dependabot in #2751
• chore(deps): bump golang.org/x/crypto from 0.15.0 to 0.17.0 in /examples/interceptors by @dependabot in #2752
• chore(deps): bump golang.org/x/crypto from 0.15.0 to 0.17.0 in /examples/http_server by @dependabot in #2753
• chore(deps): bump github.com/eapache/go-resiliency from 1.4.0 to 1.5.0 by @dependabot in #2745
• chore(deps): bump golang.org/x/crypto from 0.15.0 to 0.17.0 in /examples/txn_producer by @dependabot in #2754
• chore(deps): bump go.opentelemetry.io/otel/sdk from 1.19.0 to 1.22.0 in /examples/interceptors by @dependabot in #2767
• chore(deps): bump the golang-org-x group with 1 update by @dependabot in #2793
• chore(deps): bump go.opentelemetry.io/otel/exporters/stdout/stdoutmetric from 0.42.0 to 1.23.1 in /examples/interceptors by @dependabot in #2792

🔧 Maintenance

• fix(examples): housekeeping of code and deps by @dnwe in #2720

➕ Other Changes

• fix(test): retry MockBroker Listen for EADDRINUSE by @dnwe in #2721

New Contributors

• @maqdev made their first contribution in #2717
• @zhuliquan made their first contribution in #2472

Full Changelog: v1.42.1...v1.42.2

Version 1.42.1 (2023-11-07)

What's Changed

🐛 Fixes

• fix: make fetchInitialOffset use correct protocol by @dnwe in #2705
• fix(config): relax ClientID validation after 1.0.0 by @dnwe in #2706

Full Changelog: v1.42.0...v1.42.1

Version 1.42.0 (2023-11-02)

What's Changed

🐛 Fixes

• Asynchronously close brokers during a RefreshBrokers by @bmassemin in #2693
• Fix data race on Broker.done channel by @prestona in #2698
• fix: data race in Broker.AsyncProduce by @lzakharov in #2678
• Fix default retention time value in offset commit by @prestona in #2700
• fix(txmgr): ErrOffsetsLoadInProgress is retriable by @dnwe in #2701

🔧 Maintenance

• chore(ci): improve ossf scorecard result by @dnwe in #2685
• chore(ci): add kafka 3.6.0 to FVT and versions by @dnwe in #2692

➕ Other Changes

• chore(ci): ossf scorecard.yml by @dnwe in #2683
• fix(ci): always run CodeQL on every commit by @dnwe in #2689
• chore(doc): add OpenSSF Scorecard badge by @dnwe in #2691

New Contributors

• @bmassemin made their first contribution in #2693
• @lzakharov made their first contribution in #2678

Full Changelog: v1.41.3...v1.42.0

Version 1.41.3 (2023-10-17)

What's Changed

🐛 Fixes

• fix: pre-compile regex for parsing kafka version by @qshuai in #2663
• fix(client): ignore empty Metadata responses when refreshing by @HaoSunUber in #2672

📦 Dependency updates

• chore(deps): bump the golang-org-x group with 2 updates by @dependabot in #2661
• chore(deps): bump golang.org/x/net from 0.16.0 to 0.17.0 by @dependabot in #2671

📝 Documentation

• fix(docs): correct topic name in rebalancing strategy example by @maksadbek in #2657

New Contributors

• @maksadbek made their first contribution in #2657
• @qshuai made their first contribution in #2663

Full Changelog: v1.41.2...v1.41.3

Version 1.41.2 (2023-09-12)

What's Changed

🎉 New Features / Improvements

• perf: Alloc records in batch by @ronanh in #2646

🐛 Fixes

• fix(consumer): guard against nil client by @dnwe in #2636
• fix(consumer): don't retry session if ctx canceled by @dnwe in #2642
• fix: use least loaded broker to refresh metadata by @HaoSunUber in #2645

📦 Dependency updates

• chore(deps): bump the golang-org-x group with 1 update by @dependabot in #2641

New Contributors

• @HaoSunUber made their first contribution in #2645

Full Changelog: v1.41.1...v1.41.2