Wrap error

carsonip · carsonip · commit b5afff60e8b7 · 2025-11-03T18:31:54.000Z
diff --git a/kafka/consumer.go b/kafka/consumer.go
@@ -367,7 +367,7 @@ func (c *Consumer) Run(ctx context.Context) error {
 				continue
 			}
 
-			return err
+			return fmt.Errorf("consumer fetch error: %w", err)
 		}
 	}
 }

Original file line number	Diff line number	Diff line change
`@@ -367,7 +367,7 @@ func (c *Consumer) Run(ctx context.Context) error {`
`367`	`367`	`continue`
`368`	`368`	`}`
`369`	`369`
`370`		`- return err`
	`370`	`+ return fmt.Errorf("consumer fetch error: %w", err)`
`371`	`371`	`}`
`372`	`372`	`}`
`373`	`373`	`}`