From 7f4e95cdcf10f1e5357ef46ad376625fd43e5b5e Mon Sep 17 00:00:00 2001 From: Joseph Anthony Pasquale Holsten Date: Fri, 13 Mar 2015 06:10:23 -0700 Subject: [PATCH] sort consumer thread ids by hashcode --- core/src/main/scala/kafka/consumer/TopicCount.scala | 1 + core/src/main/scala/kafka/utils/ZkUtils.scala | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/consumer/TopicCount.scala b/core/src/main/scala/kafka/consumer/TopicCount.scala index 0954b3c..cbe6a9d 100644 --- a/core/src/main/scala/kafka/consumer/TopicCount.scala +++ b/core/src/main/scala/kafka/consumer/TopicCount.scala @@ -32,6 +32,7 @@ private[kafka] trait TopicCount { case class ConsumerThreadId(consumer: String, threadId: Int) extends Ordered[ConsumerThreadId] { override def toString = "%s-%d".format(consumer, threadId) + override def hashCode = toString.hashCode def compare(that: ConsumerThreadId) = toString.compare(that.toString) } diff --git a/core/src/main/scala/kafka/utils/ZkUtils.scala b/core/src/main/scala/kafka/utils/ZkUtils.scala index 7ae999e..7fbc452 100644 --- a/core/src/main/scala/kafka/utils/ZkUtils.scala +++ b/core/src/main/scala/kafka/utils/ZkUtils.scala @@ -686,7 +686,7 @@ object ZkUtils extends Logging { } } for ( (topic, consumerList) <- consumersPerTopicMap ) - consumersPerTopicMap.put(topic, consumerList.sortWith((s,t) => s < t)) + consumersPerTopicMap.put(topic, consumerList.sortWith((s,t) => s.hashCode < t.hashCode)) consumersPerTopicMap } -- 2.3.0