Merge pull request #1091 from twmb/fix

twmb · web-flow · commit b02944b2098b · 2025-09-02T16:02:37.000-06:00
kgo: fix panic in metadata updates from inconsistent broker state
diff --git a/pkg/kgo/metadata.go b/pkg/kgo/metadata.go
@@ -870,6 +870,7 @@ func (cl *Client) mergeTopicPartitions(
 					"topic", topic,
 					"partition", part,
 				)
+				*newTP = *oldTP
 				retryWhy.add(topic, int32(part), errMissingTopicID)
 				continue
 			}

Original file line number	Diff line number	Diff line change
`@@ -870,6 +870,7 @@ func (cl *Client) mergeTopicPartitions(`
`870`	`870`	`"topic", topic,`
`871`	`871`	`"partition", part,`
`872`	`872`	`)`
	`873`	`+ newTP = oldTP`
`873`	`874`	`retryWhy.add(topic, int32(part), errMissingTopicID)`
`874`	`875`	`continue`
`875`	`876`	`}`