public class DiskThroughputListener extends Object implements ResourceUsageListener
Modifier and Type | Method and Description |
---|---|
double |
quota()
Used by corresponding task to get the resource quota
|
void |
setQuota(double quota)
Used by
ResourceUsageManager to set the resource quota for corresponding task which registers the listener |
kafka.utils.Throttler |
throttler() |
public void setQuota(double quota)
ResourceUsageListener
ResourceUsageManager
to set the resource quota for corresponding task which registers the listenersetQuota
in interface ResourceUsageListener
public double quota()
ResourceUsageListener
quota
in interface ResourceUsageListener
public kafka.utils.Throttler throttler()