-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33049/
-----------------------------------------------------------
(Updated Aug. 15, 2015, 12:43 a.m.)
Review request for kafka, Joel Koshy and Jun Rao.
Bugs: KAFKA-2084
https://issues.apache.org/jira/browse/KAFKA-2084
Repository: kafka
Description (updated)
-------
Signed-off-by: Aditya Auradkar <aaurad...@linkedin.com>
Addressing Joel's comments
Minor imports changes
Added testcase to verify that replication traffic is not throttled
Tmp commit
Fixing test failure
Minor
Addressing Joel's comments
Addressing comments
Addressing comments
Addressing Juns comments
Minor checkstyle changes
fixed test case
Addressing Juns comments
Addressing Juns comments
Addressing Juns comments
Minor change
Minor change
Moving MockTime back to test
Addressing Joels comments
Minor import change
Addressing joels comments
Diffs (updated)
-----
build.gradle 1b67e628c2fca897177c12b6afad9a8700fffd1f
clients/src/main/java/org/apache/kafka/common/metrics/Quota.java
d82bb0c055e631425bc1ebbc7d387baac76aeeaa
clients/src/main/java/org/apache/kafka/common/metrics/QuotaViolationException.java
a451e5385c9eca76b38b425e8ac856b2715fcffe
clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java
ca823fd4639523018311b814fde69b6177e73b97
clients/src/main/java/org/apache/kafka/common/metrics/stats/Rate.java
98429da34418f7f1deba1b5e44e2e6025212edb3
clients/src/test/java/org/apache/kafka/common/metrics/MetricsTest.java
544e120594de78c43581a980b1e4087b4fb98ccb
core/src/main/scala/kafka/server/ClientQuotaManager.scala PRE-CREATION
core/src/main/scala/kafka/server/KafkaApis.scala
7ea509c2c41acc00430c74e025e069a833aac4e7
core/src/main/scala/kafka/server/KafkaConfig.scala
a06f0bd40e2f90972b44b80a106f98f3d50e5e2b
core/src/main/scala/kafka/server/KafkaServer.scala
84d4730ac634f9a5bf12a656e422fea03ad72da8
core/src/main/scala/kafka/server/ReplicaManager.scala
2e0bbcd6e4f0e38997ea18202b249ee3553640ec
core/src/main/scala/kafka/server/ThrottledResponse.scala PRE-CREATION
core/src/main/scala/kafka/utils/ShutdownableThread.scala
fc226c863095b7761290292cd8755cd7ad0f155c
core/src/test/scala/integration/kafka/api/QuotasTest.scala PRE-CREATION
core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala
PRE-CREATION
core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala
e26a7306a6ea3104b3fa3df60006c0a473bfb2cc
core/src/test/scala/unit/kafka/server/ThrottledResponseExpirationTest.scala
PRE-CREATION
Diff: https://reviews.apache.org/r/33049/diff/
Testing
-------
Thanks,
Aditya Auradkar
