This is a small release containing two minor features and a few behavior
improvements. The MarkedOffsets function allows for manually committing
marked offsets if you override OnPartitionsRevoked, and
UnsafeAbortBufferedRecords allows for forcefully dropping anything being
produced (albeit with documented caveats and downsides)
The client now guards against a broker that advertises FetchRequest v13+ (which
only uses TopicIDs) but does not actually return / use TopicIDs. If you have
an old IBP configured, the broker will not use TopicIDs even if the broker
indicates it should. The client will now pin fetching to a max version of 12 if
a topic has no TopicID.
The client now sets a record's Topic field earlier to DefaultProduceTopic,
which allows the Topic field to be known present (or known non-present) in
the OnRecordBuffered hook.
Lastly, we now universally use Go 1.19 atomic types if compiled with 1.19+. Go
uses compiler intrinsics to ensure proper int64 / uint64 alignment within
structs for the atomic types; Go does not ensure plain int64 / uint64 are
properly aligned. A lot of work previously went into ensuring alignment and
having a GitHub workflow that ran go vet on qemu armv7 emulation, but
apparently that was not comprehensive enough. Now, if you use a 32 bit arch, it
is recommended to just compile with 1.19+.
This patch release fixes two bugs introduced with v1.10.0. These bugs are not
encountered in when using the client to simply consume or produce. Only admin
usages of the client may encounter the bugs this patch is fixing.
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 merge` will merge this PR after your CI passes on it
- `@dependabot squash and merge` will squash and merge this PR after your CI passes on it
- `@dependabot cancel merge` will cancel a previously requested merge and block automerging
- `@dependabot reopen` will reopen this PR if it is closed
- `@dependabot close` will close this PR and stop Dependabot recreating it. You can achieve the same result by closing it manually
- `@dependabot show 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)
Bumps github.com/twmb/franz-go/pkg/kadm from 1.10.0 to 1.11.0.
Changelog
Sourced from github.com/twmb/franz-go/pkg/kadm's changelog.
Commits
a90ab8a
Merge pull request #306 from twmb/1.11.080073c5
CHANGELOG: fixup v1.11.0 bullets7a1484d
CHANGELOG: note incoming v1.11.09beb8cd
Merge pull request #305 from twmb/1.11.0e81c929
Merge pull request #303 from twmb/no-kip-792-proto09d8b77
Revert "kmsg: commit new ConsumerMemberMetadata for KIP-792"476f540
Merge pull request #302 from twmb/unsafe_abortd1b6897
kgo: add UnsafeAbortBufferedRecordsb942117
Merge pull request #280 from twmb/marked_offsetse1206c0
Merge pull request #301 from twmb/minorDependabot 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 merge` will merge this PR after your CI passes on it - `@dependabot squash and merge` will squash and merge this PR after your CI passes on it - `@dependabot cancel merge` will cancel a previously requested merge and block automerging - `@dependabot reopen` will reopen this PR if it is closed - `@dependabot close` will close this PR and stop Dependabot recreating it. You can achieve the same result by closing it manually - `@dependabot show