diff --git a/control-plane/pkg/autoscaler/config.go b/control-plane/pkg/autoscaler/config.go index 9b84e08785..a8798eb6cc 100644 --- a/control-plane/pkg/autoscaler/config.go +++ b/control-plane/pkg/autoscaler/config.go @@ -38,7 +38,6 @@ func defaultConfig() *AutoscalerConfig { AutoscalingPollingIntervalAnnotation: DefaultPollingInterval, AutoscalingCooldownPeriodAnnotation: DefaultCooldownPeriod, AutoscalingLagThreshold: DefaultLagThreshold, - AutoscalingActivationLagThreshold: DefaultActivationLagThreshold, }, } } diff --git a/control-plane/pkg/autoscaler/keda/keda.go b/control-plane/pkg/autoscaler/keda/keda.go index 0920fb3e12..9aadbc9101 100644 --- a/control-plane/pkg/autoscaler/keda/keda.go +++ b/control-plane/pkg/autoscaler/keda/keda.go @@ -62,11 +62,6 @@ func GenerateScaleTriggers(cg *kafkainternals.ConsumerGroup, triggerAuthenticati return nil, err } - activationLagThreshold, err := GetInt32ValueFromMap(cg.Annotations, autoscaler.AutoscalingActivationLagThreshold, aconfig.AutoscalerDefaults[autoscaler.AutoscalingActivationLagThreshold]) - if err != nil { - return nil, err - } - allowIdleConsumers := "false" if cg.Status.Placements != nil { allowIdleConsumers = "true" @@ -74,12 +69,11 @@ func GenerateScaleTriggers(cg *kafkainternals.ConsumerGroup, triggerAuthenticati for _, topic := range cg.Spec.Template.Spec.Topics { triggerMetadata := map[string]string{ - "bootstrapServers": bootstrapServers, - "consumerGroup": consumerGroup, - "topic": topic, - "lagThreshold": strconv.Itoa(int(*lagThreshold)), - "activationLagThreshold": strconv.Itoa(int(*activationLagThreshold)), - "allowIdleConsumers": allowIdleConsumers, + "bootstrapServers": bootstrapServers, + "consumerGroup": consumerGroup, + "topic": topic, + "lagThreshold": strconv.Itoa(int(*lagThreshold)), + "allowIdleConsumers": allowIdleConsumers, } trigger := kedav1alpha1.ScaleTriggers{