Version 1.41.0 (2023-08-21) #2617

dnwe announced in Announcements

dnwe
Aug 21, 2023
Maintainer

What's Changed

🚨 Breaking Changes

Note: this version of Sarama has had a big overhaul in its adherence to the use of the right Kafka protocol versions for the given Config Version. It has also bumped the default Version set in Config (where one is not supplied) to 2.1.0. This is in preparation for Kafka 4.0 dropping support for protocol versions older than 2.1. If you are using Sarama against Kafka clusters older than v2.1.0, or using it against Azure EventHubs then you will likely have to change your application code to pin to the appropriate Version.

chore(config): make DefaultVersion V2_0_0_0 by @dnwe in chore(config): make DefaultVersion V2_0_0_0 #2572
chore(config): make DefaultVersion V2_1_0_0 by @dnwe in chore(config): make DefaultVersion V2_1_0_0 #2574

🎉 New Features / Improvements

Implement resolve_canonical_bootstrap_servers_only by @gebn in Implement resolve_canonical_bootstrap_servers_only #2156
feat: sleep when throttled (KIP-219) by @hindessm in feat: sleep when throttled (KIP-219) #2536
feat: add isValidVersion to protocol types by @dnwe in feat: add isValidVersion to protocol types #2538
fix(consumer): use newer LeaveGroup as appropriate by @dnwe in fix(consumer): use newer LeaveGroup as appropriate #2544
Add support for up to version 4 List Groups API by @prestona in Add support for up to version 4 List Groups API #2541
fix(producer): use newer ProduceReq as appropriate by @dnwe in fix(producer): use newer ProduceReq as appropriate #2546
fix(proto): ensure req+resp requiredVersion match by @dnwe in fix(proto): ensure req+resp requiredVersion match #2548
chore(proto): permit CreatePartitionsRequest V1 by @dnwe in chore(proto): permit CreatePartitionsRequest V1 #2549
chore(proto): permit AlterConfigsRequest V1 by @dnwe in chore(proto): permit AlterConfigsRequest V1 #2550
chore(proto): permit DeleteGroupsRequest V1 by @dnwe in chore(proto): permit DeleteGroupsRequest V1 #2551
fix(proto): correct JoinGroup usage for wider version range by @dnwe in fix(proto): correct JoinGroup usage for wider version range #2553
fix(consumer): use full range of FetchRequest vers by @dnwe in fix(consumer): use full range of FetchRequest vers #2554
fix(proto): use range of OffsetCommitRequest vers by @dnwe in fix(proto): use range of OffsetCommitRequest vers #2555
fix(proto): use full range of MetadataRequest by @dnwe in fix(proto): use full range of MetadataRequest #2556
fix(proto): use fuller ranges of supported proto by @dnwe in fix(proto): use fuller ranges of supported proto #2558
fix(proto): use full range of SyncGroupRequest by @dnwe in fix(proto): use full range of SyncGroupRequest #2565
fix(proto): use full range of ListGroupsRequest by @dnwe in fix(proto): use full range of ListGroupsRequest #2568
feat(proto): support for Metadata V6-V10 by @dnwe in feat(proto): support for Metadata V6-V10 #2566
fix(proto): use full ranges for remaining proto by @dnwe in fix(proto): use full ranges for remaining proto #2570
feat(proto): add remaining protocol for V2.1 by @dnwe in feat(proto): add remaining protocol for V2.1 #2573
feat: add new error for MockDeleteTopicsResponse by @javiercri in feat: add new error for MockDeleteTopicsResponse #2475
feat(gzip): switch to klauspost/compress gzip by @dnwe in feat(gzip): switch to klauspost/compress gzip #2600

🐛 Fixes

fix: correct unsupported version check by @hindessm in fix: correct unsupported version check #2528
fix: avoiding burning cpu if all partitions are paused by @napallday in fix: avoiding burning cpu if all partitions are paused #2532
extend throttling metric scope by @hindessm in extend throttling metric scope #2533
Fix printing of final metrics by @prestona in Fix printing of final metrics #2545
fix(consumer): cannot automatically fetch newly-added partitions unless restart by @napallday in fix(consumer): cannot automatically fetch newly-added partitions unless restart #2563
bug: implement unsigned modulus for partitioning with crc32 hashing by @csm8118 in bug: implement unsigned modulus for partitioning with crc32 hashing #2560
fix: avoid logging value of proxy.Dialer by @prestona in fix: avoid logging value of proxy.Dialer #2569
fix(test): add missing closes to admin client tests by @dnwe in fix(test): add missing closes to admin client tests #2594
fix(test): ensure some more clients are closed by @dnwe in fix(test): ensure some more clients are closed #2595
fix(examples): sync exactly_once and consumergroup by @dnwe in fix(examples): sync exactly_once and consumergroup #2614
fix(fvt): fresh metrics registry for each test by @dnwe in fix(fvt): fresh metrics registry for each test #2616
fix(test): flaky test TestFuncOffsetManager by @napallday in fix(test): flaky test TestFuncOffsetManager #2609

📦 Dependency updates

chore(deps): bump the golang-org-x group with 1 update by @dependabot in chore(deps): bump the golang-org-x group with 1 update #2542
chore(deps): bump the golang-org-x group with 1 update by @dependabot in chore(deps): bump the golang-org-x group with 1 update #2561
chore(deps): bump module github.com/pierrec/lz4/v4 to v4.1.18 by @dnwe in chore(deps): bump module github.com/pierrec/lz4/v4 to v4.1.18 #2589
chore(deps): bump module github.com/jcmturner/gokrb5/v8 to v8.4.4 by @dnwe in chore(deps): bump module github.com/jcmturner/gokrb5/v8 to v8.4.4 #2587
chore(deps): bump github.com/eapache/go-xerial-snappy digest to c322873 by @dnwe in chore(deps): bump github.com/eapache/go-xerial-snappy digest to c322873 #2586
chore(deps): bump module github.com/klauspost/compress to v1.16.7 by @dnwe in chore(deps): bump module github.com/klauspost/compress to v1.16.7 #2588
chore(deps): bump github.com/eapache/go-resiliency from 1.3.0 to 1.4.0 by @dependabot in chore(deps): bump github.com/eapache/go-resiliency from 1.3.0 to 1.4.0 #2598

🔧 Maintenance

fix(fvt): ensure fully-replicated at test start by @hindessm in fix(fvt): ensure fully-replicated at test start #2531
chore: rollup fvt kafka to latest three by @dnwe in chore: rollup fvt kafka to latest three #2537
Merge the two CONTRIBUTING.md's by @prestona in Merge the two CONTRIBUTING.md's #2543
fix(test): test timing error by @hindessm in fix(test): test timing error #2552
chore(ci): tidyup and improve actions workflows by @dnwe in chore(ci): tidyup and improve actions workflows #2557
fix(test): shutdown MockBroker by @dnwe in fix(test): shutdown MockBroker #2571
chore(proto): match HeartbeatResponse version by @dnwe in chore(proto): match HeartbeatResponse version #2576
chore(test): ensure MockBroker closed within test by @dnwe in chore(test): ensure MockBroker closed within test #2575
chore(test): ensure all mockresponses use version by @dnwe in chore(test): ensure all mockresponses use version #2578
chore(ci): use latest Go in actions by @dnwe in chore(ci): use latest Go in actions #2580
chore(test): speedup some slow tests by @dnwe in chore(test): speedup some slow tests #2579
chore(test): use modern protocol versions in FVT by @dnwe in chore(test): use modern protocol versions in FVT #2581
chore(test): fix a couple of leaks by @dnwe in chore(test): fix a couple of leaks #2591
feat(fvt): experiment with per-kafka-version image by @dnwe in feat(fvt): experiment with per-kafka-version image #2592
chore(ci): replace toxiproxy client dep by @dnwe in chore(ci): replace toxiproxy client dep #2593
feat(fvt): add healthcheck, depends_on and --wait by @dnwe in feat(fvt): add healthcheck, depends_on and --wait #2601
fix(fvt): handle msgset vs batchset by @dnwe in fix(fvt): handle msgset vs batchset #2603
fix(fvt): Metadata version in ensureFullyReplicated by @dnwe in fix(fvt): Metadata version in ensureFullyReplicated #2612
fix(fvt): versioned cfg for invalid topic producer by @dnwe in fix(fvt): versioned cfg for invalid topic producer #2613
chore(fvt): tweak to work across more versions by @dnwe in chore(fvt): tweak to work across more versions #2615
feat(fvt): test wider range of kafkas by @dnwe in feat(fvt): test wider range of kafkas #2605

📝 Documentation

fix(example): check if msg channel is closed by @ioanzicu in fix(example): check if msg channel is closed #2479
chore: use go install for installing sarama tools by @vigith in chore: use go install for installing sarama tools #2599

New Contributors

@gebn made their first contribution in Implement resolve_canonical_bootstrap_servers_only #2156
@prestona made their first contribution in Merge the two CONTRIBUTING.md's #2543
@ioanzicu made their first contribution in fix(example): check if msg channel is closed #2479
@csm8118 made their first contribution in bug: implement unsigned modulus for partitioning with crc32 hashing #2560
@javiercri made their first contribution in feat: add new error for MockDeleteTopicsResponse #2475
@vigith made their first contribution in chore: use go install for installing sarama tools #2599

Full Changelog: v1.40.1...v1.41.0

This discussion was created from the release Version 1.41.0 (2023-08-21).

Replies: 0 comments

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment