Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-10458

Need a way to update quota for TokenBucket registered with Sensor

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 2.7.0
    • Component/s: clients
    • Labels:
      None

      Description

      For Rate() metric with quota config, we update quota by updating config of KafkaMetric. However, it is not enough for TokenBucket, because it uses quota config on record() to properly calculate the number of tokens. Sensor passes config stored in the corresponding StatAndConfig, which currently never changes. This means that after updating quota via KafkaMetric.config, our current and only method, Sensor will record the value using old quota but then measure the value to check for quota violation using the new quota value. 

        Attachments

          Activity

            People

            • Assignee:
              dajac David Jacot
              Reporter:
              apovzner Anna Povzner
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: