Merge pull request #572 from twmb/kgo-source-log

kgo: improve a log line
twmb · Sep 21, 2023 · e2f01a2 · e2f01a2
2 parents 85ac96c + a3e5141
commit e2f01a2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/kgo/source.go b/pkg/kgo/source.go
@@ -785,7 +785,7 @@ func (s *source) fetch(consumerSession *consumerSession, doneFetch chan<- struct
 	// trigger a metadata update if we have no reload offsets. Having
 	// reload offsets *always* triggers a metadata update.
 	if updateWhy != nil {
-		why := updateWhy.reason("fetch had inner topic errors")
+		why := updateWhy.reason(fmt.Sprintf("fetch had inner topic errors from broker %d", s.nodeID))
 		if !reloadOffsets.loadWithSessionNow(consumerSession, why) {
 			if updateWhy.isOnly(kerr.UnknownTopicOrPartition) || updateWhy.isOnly(kerr.UnknownTopicID) {
 				s.cl.triggerUpdateMetadata(false, why)