svn commit: r1229876 - /incubator/kafka/trunk/core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala

[ju...@apache.org]

Author: junrao
Date: Wed Jan 11 02:53:04 2012
New Revision: 1229876

URL: http://svn.apache.org/viewvc?rev=1229876&view=rev
Log:
trivial fix to make output of ConsumerOffsetChecker sorted

Modified:
    incubator/kafka/trunk/core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala

Modified: incubator/kafka/trunk/core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala?rev=1229876&r1=1229875&r2=1229876&view=diff
==============================================================================
--- incubator/kafka/trunk/core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala (original)
+++ incubator/kafka/trunk/core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala Wed Jan 11 02:53:04 2012
@@ -80,7 +80,7 @@ object ConsumerOffsetChecker extends Log
   private def processTopic(zkClient: ZkClient, group: String, topic: String) {
     val bidsPids = ZkUtils.getChildrenParentMayNotExist(
       zkClient, "/consumers/%s/offsets/%s".format(group, topic)).toList
-    bidsPids.foreach {
+    bidsPids.sorted.foreach {
       bidPid => processPartition(zkClient, group, topic, bidPid)
     }
   }
@@ -140,7 +140,7 @@ object ConsumerOffsetChecker extends Log
       debug("zkConnect = %s; topics = %s; group = %s".format(
         zkConnect, topicList.toString(), group))
 
-      topicList.foreach {
+      topicList.sorted.foreach {
         topic => processTopic(zkClient, group, topic)
       }