This release is tested against Kafka 3.4, and kversion can now properly version
guess 3.4. There are two external kgo features in this release and there is one
internal feature.
Externally,
Client.CommitMarkedOffsets makes committing marked offsets a bit easier
Client.UpdateSeedBrokers allows for updating seed brokers, which can be useful on extremely long lived clients.
Internally,
KIP-792 improves fencing of zombie group consumers using cooperative rebalancing
The integration test introduced in v1.11.6 was frequently failing in CI. After
some investigation, the panic is caused from PurgeTopicsFromClientwhile a
load of offsets was happening (i.e. consuming was being initialized). That
race is specifically easily triggered in the integration test.
This patch also relaxes the error stripping while consuming. While consuming,
retryable errors are stripped. The errors that were stripped was a small
specific set that was originally taken from Sarama (nearly 4yr ago). Kafka 3.4
returns a new retryable error frequently if consuming against a topic
immediately after the topic is created. This patch changes the error set to
just strip all retryable errors, since the kerr package already indicates which
errors are retryable. This is more compatible against the broker returning
errors that are retryable.
This is the last commit in the v1.11 series -- immediately after tagging this,
I will be working on v1.12 which will officially test against Kafka 3.4.
17567b0..78a12c3bugfix consumer: fix potential panic when calling PurgeTopicsFromClient
17567b0improvement kgo: always strip retryable errors when consuming
v1.11.6
v1.11.5 introduced a regression when:
Using a direct consumer (not a consumer group)
... (truncated)
Commits
7581420 Merge pull request #348 from twmb/changelog_1.12
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.11.0 to 1.12.0.
Changelog
Sourced from github.com/twmb/franz-go/pkg/kadm's changelog.
... (truncated)
Commits
7581420
Merge pull request #348 from twmb/changelog_1.1206b7770
CHANGELOG: note incoming v1.12.0a448276
Merge pull request #347 from twmb/seed_updatec5f86ea
kgo.Client: add UpdateSeedBrokers(...string) erroref44c0d
Merge pull request #272 from twmb/kip-7923e45339
group balancer: support KIP-7923a2dea6
Merge pull request #320 from celrenheit/commit-marked-offsets20a1225
Merge pull request #346 from twmb/kafka_3.4fe727f8
kversion: cut Kafka 3.4ede1adc
Merge pull request #289 from twmb/kip-866Dependabot 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