File tree Expand file tree Collapse file tree 2 files changed +26
-3
lines changed Expand file tree Collapse file tree 2 files changed +26
-3
lines changed Original file line number Diff line number Diff line change 1+ v1.20.5
2+ ===
3+
4+ This fixes a commit in 1.20.4 that accidentally broke client metrics (KIP-714)
5+ and inadvertently made a log spammy. In addition to the fix, a few logs around
6+ client metrics have been reduced in severity.
7+
8+ The new-as-of-1.20 ` OnPartitionsCallbackBlocked ` is now called in a goroutine,
9+ reducing the chance that you accidentally run into a deadlock based on how you
10+ structure handling the hook.
11+
12+ Deps have been bumped to eliminate any security scanners that flag on CVEs
13+ (even though this is a library and you can bump the dep in your own binary).
14+
15+ The ` kgo.Fetches.Errors ` doc has been expanded to account for previously
16+ undocumented errors, and updates guidance on what's retryable vs what is not.
17+ validating leader epoch changes.
18+
19+ - [ ` e86bb6c9 ` ] ( https://github.com/twmb/franz-go/commit/e86bb6c9 ) kgo: ` info=>debug ` for a few logs in client metrics
20+ - [ ` 7c7ca2b4 ` ] ( https://github.com/twmb/franz-go/commit/7c7ca2b4 ) kgo: call OnPartitionsCallbackBlocked concurrently
21+ - [ ` ebf29a4a ` ] ( https://github.com/twmb/franz-go/commit/ebf29a4a ) all: bump deps
22+ - [ ` 97b4a1d4 ` ] ( https://github.com/twmb/franz-go/commit/97b4a1d4 ) kgo.Fetches.Errors doc: clarify && expand for two undoc'd errors
23+ - [ ` 13ea38e3 ` ] ( https://github.com/twmb/franz-go/commit/13ea38e3 ) ** bug** kgo: fix remaining usage of kgo.maxVers/kgo.maxVersion
24+
125v1.20.4
226===
327
Original file line number Diff line number Diff line change @@ -174,9 +174,8 @@ type ConsumerBalancerBalance interface {
174174 Balance (* ConsumerBalancer , map [string ]int32 ) IntoSyncAssignment
175175}
176176
177- // ParseConsumerSyncAssignment returns an assignment as specified a
178- // kmsg.ConsumerMemberAssignment, that is, the type encoded in metadata for the
179- // consumer protocol.
177+ // ParseConsumerSyncAssignment parses `assignment` as kmsg.ConsumerMemberAssignment
178+ // and returns the mapped topic => partitions assignment.
180179func ParseConsumerSyncAssignment (assignment []byte ) (map [string ][]int32 , error ) {
181180 var kassignment kmsg.ConsumerMemberAssignment
182181 if err := kassignment .ReadFrom (assignment ); err != nil {
You can’t perform that action at this time.
0 commit comments