[kafkaadmin] corrected variable

DataDog · Feb 11, 2022 · 44cbb35 · 44cbb35
1 parent 547c244
commit 44cbb35
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/kafkaadmin/throttles.go b/kafkaadmin/throttles.go
@@ -12,7 +12,7 @@ const (
 	brokerTXThrottleCfgName        = "leader.replication.throttled.rate"
 	brokerRXThrottleCfgName        = "follower.replication.throttled.rate"
 	topicThrottledLeadersCfgName   = "leader.replication.throttled.replicas"
-	topicThrottledFollowersCfgName = "leader.replication.throttled.replicas"
+	topicThrottledFollowersCfgName = "follower.replication.throttled.replicas"
 )
 
 // ThrottleConfig holds SetThrottle configs.
@@ -154,7 +154,6 @@ func (c Client) RemoveThrottle(ctx context.Context, cfg RemoveThrottleConfig) er
 	// Merge all configs into the global configuration set.
 	for i, resourceConfig := range []ResourceConfigs{topicDynamicConfigs, brokerDynamicConfigs} {
 		for name, configs := range resourceConfig {
-			// StringMapToConfigEntries
 			c := kafka.ConfigResource{
 				Name:   name,
 				Config: kafka.StringMapToConfigEntries(configs, kafka.AlterOperationSet),