Dong Lin created KAFKA-2191: ------------------------------- Summary: Measured rate should not be infinite Key: KAFKA-2191 URL: https://issues.apache.org/jira/browse/KAFKA-2191 Project: Kafka Issue Type: Bug Reporter: Dong Lin Assignee: Dong Lin
Rate.measure() is called, it calculates elapsed time as now - stat.oldest(now).lastWindowMs. But the stat.oldest(now) may equal now due to the way SampledStat is implemented. As a result, Rate.measure() may return Infinite. This bug needs to be fixed in order for quota implementation to work properly. -- This message was sent by Atlassian JIRA (v6.3.4#6332)