Version 1.40.1 (2023-07-27)

What's Changed

🎉 New Features / Improvements

• Use buffer pools for decompression by @ronanh in #2484
• feat: support for Kerberos authentication with a credentials cache. by @mrogaski in #2457

🐛 Fixes

• Fix some retry issues by @hindessm in #2517
• fix: admin retry logic by @hindessm in #2519
• Add some retry logic to more admin client functions by @hindessm in #2520
• fix: concurrent issue on updateMetadataMs by @napallday in #2522
• fix(test): allow testing of skipped test without IsTransactional panic by @hindessm in #2525

📦 Dependency updates

• chore(deps): bump the golang-org-x group with 2 updates by @dependabot in #2509
• chore(deps): bump github.com/klauspost/compress from 1.15.14 to 1.16.6 by @dependabot in #2513
• chore(deps): bump github.com/stretchr/testify from 1.8.1 to 1.8.3 by @dependabot in #2512

🔧 Maintenance

• chore(ci): migrate probot-stale to actions/stale by @dnwe in #2496
• chore(ci): bump golangci version, cleanup, depguard config by @EladLeev in #2504
• Clean up some typos and docs/help mistakes by @hindessm in #2514

➕ Other Changes

• chore(ci): add simple apidiff workflow by @dnwe in #2497
• chore(ci): bump actions/setup-go from 3 to 4 by @dependabot in #2508
• fix(comments): PauseAll and ResumeAll by @napallday in #2523

New Contributors

• @EladLeev made their first contribution in #2504
• @hindessm made their first contribution in #2514
• @ronanh made their first contribution in #2484
• @mrogaski made their first contribution in #2457

Full Changelog: v1.40.0...v1.40.1

Version 1.40.0 (2023-07-17)

What's Changed

Note: this is the first release after the transition of Sarama ownership from Shopify to IBM in #2461

🚨 Breaking Changes

• chore: migrate module to github.com/IBM/sarama by @dnwe in #2492
• fix: restore (*OffsetCommitRequest) AddBlock func by @dnwe in #2494

🐛 Fixes

• fix(consumer): don't retry FindCoordinator forever by @dnwe in #2427
• fix(metrics): fix race condition when calling Broker.Open() twice by @vincentbernat in #2428
• fix: use version 4 of DescribeGroupsRequest only if kafka broker vers… …ion is >= 2.4 by @faillefer in #2451
• Fix HighWaterMarkOffset of mocks partition consumer by @gr8web in #2447
• fix: prevent data race in balance strategy by @napallday in #2453

📦 Dependency updates

• chore(deps): bump golang.org/x/net from 0.5.0 to 0.7.0 by @dependabot in #2452

🔧 Maintenance

• chore: add kafka 3.3.2 by @dnwe in #2434
• chore(ci): remove Shopify/shopify-cla-action by @dnwe in #2489
• chore: bytes.Equal instead bytes.Compare by @testwill in #2485

New Contributors

• @dependabot made their first contribution in #2452
• @gr8web made their first contribution in #2447
• @testwill made their first contribution in #2485

Full Changelog: v1.38.1...v1.40.0

Version 1.38.1 (2023-01-22)

What's Changed

🐛 Fixes

• fix(example): correct records-number param in txn producer readme by @diallo-han in #2420
• fix: use newConsumer method in newConsumerGroup method by @Lumotheninja in #2424

📦 Dependency updates

• chore(deps): bump module github.com/klauspost/compress to v1.15.14 by @dnwe in #2410
• chore(deps): bump module golang.org/x/net to v0.5.0 by @dnwe in #2413
• chore(deps): bump module github.com/stretchr/testify to v1.8.1 by @dnwe in #2411
• chore(deps): bump module github.com/xdg-go/scram to v1.1.2 by @dnwe in #2412
• chore(deps): bump module golang.org/x/sync to v0.1.0 by @dnwe in #2414
• chore(deps): bump github.com/eapache/go-xerial-snappy digest to bf00bc1 by @dnwe in #2418

New Contributors

• @diallo-han made their first contribution in #2420
• @Lumotheninja made their first contribution in #2424

Full Changelog: v1.38.0...v1.38.1

Version 1.38.0 (2023-01-08)

What's Changed

🎉 New Features / Improvements

• feat(producer): improve memory usage of zstd encoder by using our own pool management by @rtreffer in #2375
• feat(proto): implement and use MetadataRequest v7 by @dnwe in #2388
• feat(metrics): add protocol-requests-rate metric by @auntan in #2373

🐛 Fixes

• fix(proto): track and supply leader epoch to FetchRequest by @dnwe in #2389
• fix(example): improve arg name used for tls skip verify by @michaeljmarshall in #2385
• fix(zstd): default back to GOMAXPROCS concurrency by @bgreenlee in #2404
• fix(producer): add nil check while producer is retrying by @hsweif in #2387
• fix(producer): return errors for every message in retryBatch to avoid producer hang forever by @cch123 in #2378
• fix(metrics): fix race when accessing metric registry by @vincentbernat in #2409

📦 Dependency updates

• chore(deps): bump golang.org/x/net to v0.4.0 by @dnwe in #2403

🔧 Maintenance

• chore(ci): replace set-output command in GH Action by @dnwe in #2390
• chore(ci): include kafka 3.3.1 in testing matrix by @dnwe in #2406

New Contributors

• @michaeljmarshall made their first contribution in #2385
• @bgreenlee made their first contribution in #2404
• @hsweif made their first contribution in #2387
• @cch123 made their first contribution in #2378

Full Changelog: v1.37.2...v1.38.0

Version 1.37.2 (2022-10-04)

What's Changed

🐛 Fixes

• fix: ensure updateMetaDataMs is 64-bit aligned by @dnwe in #2356

➕ Other Changes

• fix: bump go.mod specification to go 1.17 by @dnwe in #2357

Full Changelog: v1.37.1...v1.37.2

Version 1.37.1 (2022-10-04)

What's Changed

🐛 Fixes

• fix: support existing deprecated Rebalance.Strategy field usage by @spongecaptain in #2352
• fix(test): consumer group rebalance strategy compatibility by @Jacob-bzx in #2353
• fix(producer): replace time.After with time.Timer to avoid high memory usage by @Jacob-bzx in #2355

New Contributors

• @spongecaptain made their first contribution in #2352

Full Changelog: v1.37.0...v1.37.1

Version 1.37.0 (2022-09-28)

What's Changed

🚨 Breaking Changes

• Due to a change in github.com/klauspost/compress v1.15.10, Sarama v1.37.0 requires Go 1.17 going forward, unfortunately due to an oversight this wasn't reflected in the go.mod declaration at time of release.

🎉 New Features / Improvements

• feat(consumer): support multiple balance strategies by @Jacob-bzx in #2339
• feat(producer): transactional API by @ryarnyah in #2295
• feat(mocks): support key in MockFetchResponse. by @Skandalik in #2328

🐛 Fixes

• fix: avoid panic when Metadata.RefreshFrequency is 0 by @Jacob-bzx in #2329
• fix(consumer): avoid pushing unrelated responses to paused children by @pkoutsovasilis in #2317
• fix: prevent metrics leak with cleanup by @auntan in #2340
• fix: race condition(may panic) when closing consumer group by @Jacob-bzx in #2331
• fix(consumer): default ResetInvalidOffsets to true by @dnwe in #2345
• Validate the Config when creating a mock producer/consumer by @joewreschnig in #2327

📦 Dependency updates

• chore(deps): bump module github.com/pierrec/lz4/v4 to v4.1.16 by @dnwe in #2335
• chore(deps): bump golang.org/x/net digest to bea034e by @dnwe in #2333
• chore(deps): bump golang.org/x/sync digest to 7f9b162 by @dnwe in #2334
• chore(deps): bump golang.org/x/net digest to f486391 by @dnwe in #2348
• chore(deps): bump module github.com/shopify/toxiproxy/v2 to v2.5.0 by @dnwe in #2336
• chore(deps): bump module github.com/klauspost/compress to v1.15.11 by @dnwe in #2349
• chore(deps): bump module github.com/pierrec/lz4/v4 to v4.1.17 by @dnwe in #2350

🔧 Maintenance

• chore(ci): bump kafka-versions to latest by @dnwe in #2346
• chore(ci): bump go-versions to N and N-1 by @dnwe in #2347

New Contributors

• @Jacob-bzx made their first contribution in #2329
• @pkoutsovasilis made their first contribution in #2317
• @Skandalik made their first contribution in #2328
• @auntan made their first contribution in #2340
• @ryarnyah made their first contribution in #2295

Full Changelog: v1.36.0...v1.37.0

Version 1.36.0 (2022-08-11)

What's Changed

🎉 New Features / Improvements

• feat: add option to propagate OffsetOutOfRange error by @dkolistratova in #2252
• feat(producer): expose ProducerMessage.byteSize() function by @k8scat in #2315
• feat(metrics): track consumer fetch request rates by @dnwe in #2299

🐛 Fixes

• fix(consumer): avoid submitting empty fetch requests when paused by @raulnegreiros in #2143

📦 Dependency updates

• chore(deps): bump module github.com/klauspost/compress to v1.15.9 by @dnwe in #2304
• chore(deps): bump golang.org/x/net digest to c7608f3 by @dnwe in #2301
• chore(deps): bump golangci/golangci-lint-action action to v3 by @dnwe in #2311
• chore(deps): bump golang.org/x/net digest to 07c6da5 by @dnwe in #2307
• chore(deps): bump github actions versions (major) by @dnwe in #2313
• chore(deps): bump module github.com/jcmturner/gofork to v1.7.6 by @dnwe in #2305
• chore(deps): bump golang.org/x/sync digest to 886fb93 by @dnwe in #2302
• chore(deps): bump module github.com/jcmturner/gokrb5/v8 to v8.4.3 by @dnwe in #2303

🔧 Maintenance

• chore: add kafka 3.1.1 to the version matrix by @dnwe in #2300

➕ Other Changes

• Migrate off probot-CLA to new GitHub Action by @cursedcoder in #2294
• Forgot to remove cla probot by @cursedcoder in #2297
• chore(lint): re-enable a small amount of go-critic by @dnwe in #2312

New Contributors

• @cursedcoder made their first contribution in #2294
• @dkolistratova made their first contribution in #2252
• @k8scat made their first contribution in #2315

Full Changelog: v1.35.0...v1.36.0

Version 1.35.0 (2022-07-22)

What's Changed

🐛 Fixes

• fix: fix metadata retry backoff invalid when get metadata failed by @Stephan14 in #2256
• fix(balance): sort and de-deplicate memberIDs by @dnwe in #2285
• fix: prevent DescribeLogDirs hang in admin client by @zerowidth in #2269
• fix: include assignment-less members in SyncGroup by @dnwe in #2292

📦 Dependency updates

• chore(deps): bump module github.com/stretchr/testify to v1.8.0 by @dnwe in #2284
• chore(deps): bump module github.com/eapache/go-resiliency to v1.3.0 by @dnwe in #2283
• chore(deps): bump golang.org/x/net digest to 1185a90 by @dnwe in #2279
• chore(deps): bump module github.com/pierrec/lz4/v4 to v4.1.15 by @dnwe in #2281
• chore(deps): bump module github.com/klauspost/compress to v1.15.8 by @dnwe in #2280

🔧 Maintenance

• chore: rename any func to avoid identifier by @dnwe in #2272
• chore: add and test against kafka 3.2.0 by @dnwe in #2288
• chore: document Fetch protocol fields by @dnwe in #2289

➕ Other Changes

• chore(ci): fix redirect with GITHUB_STEP_SUMMARY by @dnwe in #2286
• fix(test): permit ECONNRESET in TestInitProducerID by @dnwe in #2287
• fix: ensure empty or devel version valid by @dnwe in #2291

New Contributors

• @zerowidth made their first contribution in #2269

Full Changelog: v1.34.1...v1.35.0

Version 1.34.1 (2022-06-07)

What's Changed

🐛 Fixes

• fix(examples): check session.Context().Done() in examples/consumergroup by @zxc111 in #2240
• fix(protocol): move AuthorizedOperations into GroupDescription of DescribeGroupsResponse by @aiquestion in #2247
• fix(protocol): tidyup DescribeGroupsResponse by @dnwe in #2248
• fix(consumer): range balance strategy not like reference by @njhartwell in #2245

🔧 Maintenance

• chore(ci): experiment with using tparse by @dnwe in #2236
• chore(deps): bump thirdparty dependencies to latest releases by @dnwe in #2242

New Contributors

• @zxc111 made their first contribution in #2240
• @njhartwell made their first contribution in #2245

Full Changelog: v1.34.0...v1.34.1