This release contains a few new APIs, one behavior change, and one minor bugfix.
Bug fixes
Previously, HookBrokerRead and HookBrokerE2E could not be used at the same
time. This has been fixed.
Behavior changes
PauseFetch{Topics,Partitions} now causes the client to drop all buffered
fetches and kill all in-flight fetch requests. Importantly, this also means
that once you pause, it is no longer possible for what you paused to be
returned while polling. Previously, the client made no attempt to clear
internal buffers / in flight requests, meaning you could receive paused data
for a while.
Seed brokers now show up in logs as seed_### rather than seed ### (an
underscore has been added).
Features
kgo.Offset now has an EpochOffset getter function that allows access
to the actual epoch and offset that are inside the opaque Offset type.
AddConsumePartitions allows adding individual partitions to consume, and
the new counterpart RemoveConsumePartitions allows removing individual
partitions from being consumed. Removing is different from purging, please
see the docs.
KeepRetryableFetchErrors bubbles up retryable errors to the end user that
are encountered while fetching. By default, these errors are stripped.
kversion now supports Kafka 3.5
kversion now supports version guessing against KRaft by default
kgo.DialTLS now exists to even more easily opt into TLS.
kgo.Client.Opts now exists to return the original options that were used
to configure the client, making initializing new clients easier.
kgo.NodeName returns a string form of a broker node name. Internally, seed
brokers use math.MinInt32 for node IDs, which shows up as massively negative
numbers in logs sometimes. NodeName can help convert that to seed_<#>.
Relevant commits
c3b083bimprovement kgo: do not returned paused topics/partitions after pausing
e224e90bugfix kgo: allow HookBrokerRead and HookBrokerE2E to both be called
875761afeature kgo Offset: add EpochOffset getter field
c5d0fc5 kgo: add a debug log for stripping retryable errors from fetches
b45d663 kgo: add more context to opportunistic metadata loads while fetching
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)
⚠️ Dependabot is rebasing this PR ⚠️
Rebasing might not happen immediately, so don't worry if this takes some time.
Note: if you make any changes to this PR yourself, they will take precedence over the rebase.
Bumps github.com/twmb/franz-go/pkg/kadm from 1.13.0 to 1.14.0.
Changelog
Sourced from github.com/twmb/franz-go/pkg/kadm's changelog.
... (truncated)
Commits
f132eaa
Merge pull request #504 from twmb/bump_kmsgfa4e091
franz-go: bump kmsg to v1.6.17182514
Merge pull request #503 from twmb/kmsg_noretract23c38ff
plugin/klogrus: use fmt.Sprint7ea9b09
pkg/kmsg: avoid retract v2 directive063ab3e
Merge pull request #502 from twmb/v1.14-changelogcd58477
CHANGELOG: note incoming v1.14118e822
Merge pull request #470 from JGShaw/master6fb7260
Merge pull request #498 from twmb/ftbc4b0e4
Merge pull request #496 from twmb/kadm_listDependabot 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