----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31140/ -----------------------------------------------------------
Review request for kafka. Bugs: KAFKA-1953 https://issues.apache.org/jira/browse/KAFKA-1953 Repository: kafka Description ------- KAFKA-1953; KAFKA-1962; Disambiguate purgatory metrics; restore delayed request metrics Diffs ----- core/src/main/scala/kafka/coordinator/ConsumerCoordinator.scala 01cf1d91b7056bea7368ae4ea1e3c3646fc33619 core/src/main/scala/kafka/coordinator/DelayedHeartbeat.scala 894d6edb4077cae081b9d4039353dd17e6f0c18f core/src/main/scala/kafka/coordinator/DelayedJoinGroup.scala 445bfa1bf8840620e10de2456875716dc66e789a core/src/main/scala/kafka/coordinator/DelayedRebalance.scala b3b3749a21d35950a975e24dd9d1d53afbfaaee4 core/src/main/scala/kafka/server/DelayedFetch.scala dd602ee2e65c2cd4ec363c75fa5d0b3c038b1ed2 core/src/main/scala/kafka/server/DelayedOperation.scala fc06b01cad3a0497800df727fa2abf60772694f2 core/src/main/scala/kafka/server/DelayedProduce.scala c229088eb4f3db414225a688e149591ae0f810e7 core/src/main/scala/kafka/server/ReplicaManager.scala ce36cc72606fb5441335f1c7466a7db8da3db499 core/src/test/scala/unit/kafka/server/DelayedOperationTest.scala 93f52d3222fc10b6d22ef6278365f6b026180418 Diff: https://reviews.apache.org/r/31140/diff/ Testing ------- Thanks, Joel Koshy