fix: better error handling for multiple election failed

steadybit · Nov 21, 2024 · 368c669 · 368c669
1 parent e7a6085
commit 368c669
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/extkafka/partition_attack_elect_new_leader.go b/extkafka/partition_attack_elect_new_leader.go
@@ -132,7 +132,7 @@ func (f kafkaBrokerElectNewLeaderAttack) Start(ctx context.Context, state *Kafka
 					Level:   extutil.Ptr(action_kit_api.Warn),
 					Message: fmt.Sprintf("Error while electing leader for topic '%s', partition %d, error is: %s", t, partition, result.Err.Error()),
 				})
-				errs = append(errs, result.Err)
+				errs = append(errs, errors.New(fmt.Sprintf("Error while electing leader for topic '%s', partition %d, error is: %s", t, partition, result.Err.Error())))
 			} else {
 				messages = append(messages, action_kit_api.Message{
 					Level:   extutil.Ptr(action_kit_api.Info),