Skip to content

Commit

Permalink
use right nil type to fix partition reassignments
Browse files Browse the repository at this point in the history
  • Loading branch information
Martin Schneppenheim committed Nov 15, 2021
1 parent 236d68c commit 2b50411
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions e2e/topic.go
Original file line number Diff line number Diff line change
Expand Up @@ -107,8 +107,8 @@ func (s *Service) executeAlterPartitionAssignments(ctx context.Context, req *kms
}
for _, topic := range res.Topics {
for _, partition := range topic.Partitions {
err = kerr.TypedErrorForCode(partition.ErrorCode)
if err != nil {
typedErr = kerr.TypedErrorForCode(partition.ErrorCode)
if typedErr != nil {
return fmt.Errorf("inner Kafka partition error on partition '%v': %w", partition.Partition, err)
}
}
Expand Down

0 comments on commit 2b50411

Please sign in to comment.