You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jj...@apache.org on 2015/02/19 01:37:48 UTC
kafka git commit: KAFKA-1914; follow-up to fix SimpleFetchTest;
reviewed by Joel Koshy
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 <aa...@linkedin.com>
Authored: Wed Feb 18 16:36:58 2015 -0800
Committer: Joel Koshy <jj...@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());
}
}