Skip to content

Conversation

@pmady
Copy link
Contributor

@pmady pmady commented Dec 3, 2025

Provide a description of what has been changed

Checklist

  • Commits are signed with Developer Certificate of Origin (DCO)

Fixes #

@pmady pmady requested a review from a team as a code owner December 3, 2025 17:15
@netlify
Copy link

netlify bot commented Dec 3, 2025

Deploy Preview for keda ready!

Name Link
🔨 Latest commit 49c0db2
🔍 Latest deploy log https://app.netlify.com/projects/keda/deploys/6930707c200e370008b98d4d
😎 Deploy Preview https://deploy-preview-1663--keda.netlify.app
📱 Preview on mobile
Toggle QR Code...

QR Code

Use your smartphone camera to open QR code link.

To edit notification comments on pull requests, go to your Netlify project configuration.

@github-actions
Copy link

github-actions bot commented Dec 3, 2025

Thank you for your contribution! 🙏 We will review your PR as soon as possible.

While you are waiting, make sure to:

  • Add your contribution to all applicable KEDA versions
  • GitHub checks are passing
  • Is the DCO check failing? Here is how you can fix DCO issues

Learn more about:

The lagThreshold parameter description was misleading. Since the Kafka
scaler uses AverageValue metric type by default, the HPA algorithm
divides the total lag by the number of replicas. Therefore, lagThreshold
is an average target value, not the total lag.

Fixes kedacore#1653

Signed-off-by: pmady <[email protected]>
@pmady pmady force-pushed the fix/kafka-lagthreshold-description branch from adf016c to 49c0db2 Compare December 3, 2025 17:16
- `consumerGroup` - Name of the consumer group used for checking the offset on the topic and processing the related lag.
- `topic` - Name of the topic on which processing the offset lag. (Optional, see note below)
- `lagThreshold` - Target value for the total lag (sum of all partition lags) to trigger scaling actions. (Default: `10`, Optional)
- `lagThreshold` - Average target value to trigger scaling actions. (Default: `10`, Optional)
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Hello
Could you elaborate this? Although AverageValue is the default metric type (set at scaler level), it can also be Value.

Checking the current scaler code, it sums all the lags per partition and return the total value, so the HPA controller calculates avg or not depending on metric type

@pmady pmady closed this Dec 8, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants