fix typed error check (#295)

weeco · web-flow · commit 37773f9f71ff · 2025-05-05T12:22:11.000+02:00
diff --git a/e2e/topic.go b/e2e/topic.go
@@ -121,9 +121,9 @@ func (s *Service) executeCreatePartitions(ctx context.Context, req *kmsg.CreateP
 	}
 
 	for _, topic := range res.Topics {
-		typedErr := kerr.TypedErrorForCode(topic.ErrorCode)
-		if typedErr != nil {
-			return fmt.Errorf("inner Kafka error: %w", typedErr)
+		err := kerr.ErrorForCode(topic.ErrorCode)
+		if err != nil {
+			return fmt.Errorf("inner Kafka error: %w", err)
 		}
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -121,9 +121,9 @@ func (s Service) executeCreatePartitions(ctx context.Context, req kmsg.CreateP`
`121`	`121`	`}`
`122`	`122`
`123`	`123`	`for _, topic := range res.Topics {`
`124`		`- typedErr := kerr.TypedErrorForCode(topic.ErrorCode)`
`125`		`- if typedErr != nil {`
`126`		`- return fmt.Errorf("inner Kafka error: %w", typedErr)`
	`124`	`+ err := kerr.ErrorForCode(topic.ErrorCode)`
	`125`	`+ if err != nil {`
	`126`	`+ return fmt.Errorf("inner Kafka error: %w", err)`
`127`	`127`	`}`
`128`	`128`	`}`
`129`	`129`