dajac commented on a change in pull request #8933:
URL: https://github.com/apache/kafka/pull/8933#discussion_r456423986



##########
File path: core/src/main/scala/kafka/server/ClientQuotaManager.scala
##########
@@ -154,32 +180,40 @@ object ClientQuotaManager {
  * @param config @ClientQuotaManagerConfig quota configs
  * @param metrics @Metrics Metrics instance
  * @param quotaType Quota type of this quota manager
+ * @param quotaEnforcementType Quota enforcement type of this quota manager. 
Refers to the
+ *                             documentation of {recordAndGetThrottleTimeMs} 
for details
  * @param time @Time object to use
+ * @param threadNamePrefix The thread prefix to use
+ * @param clientQuotaCallback An optional @ClientQuotaCallback
  */
 class ClientQuotaManager(private val config: ClientQuotaManagerConfig,
                          private val metrics: Metrics,
                          private val quotaType: QuotaType,
+                         private val quotaEnforcementType: 
QuotaEnforcementType,

Review comment:
       Yes, you are right. I was trying to make `ClientQuotaManager` a generic 
base class for all client quotas. I will still try to extract the real common 
parts in a base class once but that will be for a follow-up PR.




----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to