go.mod: bump github.com/twmb/franz-go from 1.20.7 to 1.21.2

[dependabot]

Bumps github.com/twmb/franz-go from 1.20.7 to 1.21.2.

Changelog

Sourced from github.com/twmb/franz-go's changelog.

v1.21.2

This patch release contains two narrow bug fixes and one small feature. Deps are also bumped so that you are force-pinned to a klauspost/compress version that has a stack-splitting bugfix that sometimes affected franz-go.

• PurgeTopicsFromConsuming now correctly persists deleted topics if you also had specific topics paused. Previously, when a topic had partition-level pauses, unpausing the topic itself (while keeping specific partitions paused) was bugged and the topic was stuck in an "all paused" state (thanks @​gorakdev!).

• PollFetches no longer surfaces a spurious UNSTABLE_OFFSET_COMMIT fetch error when an OffsetFetch retry is canceled mid-wait by a rebalance or client close. Observed flaking TestTxnEtl/sticky/848 on KIP-848 consumer groups under transactional load.

• The MSK IAM SASL mechanism now honors AWS_REGION when the broker hostname does not match the standard MSK URL format, allowing connections through custom DNS names (e.g. private link endpoints) (thanks @​janmoritzmeyer0210!).

Relevant commits

• 22a17320 bugfix kgo: do not inject fake fetch error when OffsetFetch retry is canceled
• 95d74ab3 bugfix kgo: fix delTopics not writing back modified pausedPartitions struct (thanks @​gorakdev!)
• 40e5a0e5 feature sasl/aws: support custom AWS MSK DNS names (thanks @​janmoritzmeyer0210!)

v1.21.1

This patch release contains a few bug fixes in the new share consumer and a few internal improvements. The highlights are noted below; if you are interested in all the improvements, check the commits.

• Share consuming no longer panics on empty batches from the broker.

• The share acking previously did not work in tandem with Record.Recycle; that has been fixed. Records that are recycled without being ack'd are now also auto-accepted.

• PurgeFetchTopics no longer panics on KIP-848 consumer groups.

• ListGroups and ListTransactions fan out to every broker and merge the responses. During a group-coordinator or transaction state leader migration, the same group or transactional ID can transiently appear in both the old and new coordinator's response, producing duplicates in the merged result. The merges now dedupe by key (first shard response wins).

... (truncated)

Commits

• 8268a5d Merge pull request #1325 from twmb/cl
• 4b31b76 CHANGELOG: note v1.21.2
• 1de5563 Merge pull request #1324 from twmb/deps
• 22a1732 kgo: do not inject fake fetch error when OffsetFetch retry is canceled
• 40e5a0e add support for custom AWS MSK dns names (#1321)
• 2d3da36 Merge pull request #1322 from paxosglobal/fix-del-topics-struct-writeback
• 10ace71 all: bump deps
• 95d74ab kgo: fix delTopics not writing back modified pausedPartitions struct
• 963be6f Merge pull request #1316 from twmb/misc
• eae16c2 changelog: note Event Hubs / metadata-v9 guards; remove unreleased note
• Additional commits viewable in compare view

Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a rebase manually by commenting @dependabot rebase.

---

Dependabot commands and options

You can trigger Dependabot actions by commenting on this PR:

• @dependabot rebase will rebase this PR
• @dependabot recreate will recreate this PR, overwriting any edits that have been made to it
• @dependabot show <dependency name> ignore conditions will show all of the ignore conditions of the specified dependency
• @dependabot ignore this major version will close this PR and stop Dependabot creating any more for this major version (unless you reopen the PR or upgrade to it yourself)
• @dependabot ignore this minor version will close this PR and stop Dependabot creating any more for this minor version (unless you reopen the PR or upgrade to it yourself)
• @dependabot ignore this dependency will close this PR and stop Dependabot creating any more for this dependency (unless you reopen the PR or upgrade to it yourself)