kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jjko...@apache.org
Subject kafka git commit: KAFKA-1914; follow-up to fix SimpleFetchTest; reviewed by Joel Koshy
Date Thu, 19 Feb 2015 00:37:48 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 8d72816f4 -> f7f8ac1a8


KAFKA-1914; follow-up to fix SimpleFetchTest; reviewed by Joel Koshy


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/f7f8ac1a
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/f7f8ac1a
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/f7f8ac1a

Branch: refs/heads/trunk
Commit: f7f8ac1a8864acdbfc52326edc7cbeb9e35f4adf
Parents: 8d72816
Author: Aditya Auradkar <aauradkar@linkedin.com>
Authored: Wed Feb 18 16:36:58 2015 -0800
Committer: Joel Koshy <jjkoshy@gmail.com>
Committed: Wed Feb 18 16:37:29 2015 -0800

----------------------------------------------------------------------
 core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/f7f8ac1a/core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala b/core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala
index 525c835..fd8f32c 100644
--- a/core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala
+++ b/core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala
@@ -140,5 +140,8 @@ class SimpleFetchTest extends JUnit3Suite {
       replicaManager.readFromLocalLog(true, true, fetchInfo).get(topicAndPartition).get.info.messageSet.head.message)
     assertEquals("Reading any data can return messages up to the end of the log", messagesToLEO,
       replicaManager.readFromLocalLog(true, false, fetchInfo).get(topicAndPartition).get.info.messageSet.head.message)
+
+    assertEquals("Counts should increment after fetch", initialTopicCount+2, BrokerTopicStats.getBrokerTopicStats(topic).totalFetchRequestRate.count());
+    assertEquals("Counts should increment after fetch", initialAllTopicsCount+2, BrokerTopicStats.getBrokerAllTopicsStats().totalFetchRequestRate.count());
   }
 }


Mime
View raw message