Skip to content

Commit

Permalink
fix: network threads bad variable name
Browse files Browse the repository at this point in the history
  • Loading branch information
achoimet committed Nov 13, 2024
1 parent a147b6e commit b1af633
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions extkafka/alter_num_network_threads.go
Original file line number Diff line number Diff line change
Expand Up @@ -58,9 +58,9 @@ func (k *AlterNumberNetworkThreadsAttack) Describe() action_kit_api.ActionDescri
Parameters: []action_kit_api.ActionParameter{
durationAlter,
{
Label: "Number of IO Networks",
Label: "Number of Network Threads",
Description: extutil.Ptr("Reduce the num.network.threads to limit the broker’s ability to process network requests."),
Name: "io_networks",
Name: "network_threads",
Type: action_kit_api.Integer,
DefaultValue: extutil.Ptr("4"),
Required: extutil.Ptr(true),
Expand All @@ -71,7 +71,7 @@ func (k *AlterNumberNetworkThreadsAttack) Describe() action_kit_api.ActionDescri

func (k *AlterNumberNetworkThreadsAttack) Prepare(_ context.Context, state *AlterNumberNetworkThreadsState, 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("%.0f", request.Config["io_networks"])
state.BrokerConfigValue = fmt.Sprintf("%.0f", request.Config["network_threads"])

return nil, nil
}
Expand Down

0 comments on commit b1af633

Please sign in to comment.