fix: conversion error

steadybit · Nov 12, 2024 · 1901faf · 1901faf
1 parent d37549e
commit 1901faf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/extkafka/alter_limit_connection_create_rate.go b/extkafka/alter_limit_connection_create_rate.go
@@ -71,7 +71,7 @@ func (k *AlterLimitConnectionCreateRateAttack) Describe() action_kit_api.ActionD
 
 func (k *AlterLimitConnectionCreateRateAttack) Prepare(_ context.Context, state *AlterLimitConnectionCreateRateState, request action_kit_api.PrepareActionRequestBody) (*action_kit_api.PrepareResult, error) {
 	state.BrokerID = extutil.ToInt32(request.Target.Attributes["kafka.broker.node-id"][0])
-	state.BrokerConfigValue = fmt.Sprintf("%f", request.Config["connection_rate"])
+	state.BrokerConfigValue = fmt.Sprintf("%d", int(extutil.ToInt64(request.Config["connection_rate"])))
 
 	return nil, nil
 }