You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2013/09/11 19:04:03 UTC
[18/36] git commit: KAFKA-992 follow up. Fix broken unit test
KAFKA-992 follow up. Fix broken unit test
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/7fbbb666
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/7fbbb666
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/7fbbb666
Branch: refs/heads/trunk
Commit: 7fbbb6666bef10f31301c4af17a6077e8895fa06
Parents: 14af713
Author: Neha Narkhede <ne...@gmail.com>
Authored: Mon Aug 5 13:23:55 2013 -0700
Committer: Neha Narkhede <ne...@gmail.com>
Committed: Mon Aug 5 13:23:55 2013 -0700
----------------------------------------------------------------------
core/src/test/scala/unit/kafka/utils/TestUtils.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/7fbbb666/core/src/test/scala/unit/kafka/utils/TestUtils.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/unit/kafka/utils/TestUtils.scala b/core/src/test/scala/unit/kafka/utils/TestUtils.scala
index a4dcca6..830608f 100644
--- a/core/src/test/scala/unit/kafka/utils/TestUtils.scala
+++ b/core/src/test/scala/unit/kafka/utils/TestUtils.scala
@@ -345,7 +345,7 @@ object TestUtils extends Logging {
def createBrokersInZk(zkClient: ZkClient, ids: Seq[Int]): Seq[Broker] = {
val brokers = ids.map(id => new Broker(id, "localhost", 6667))
- brokers.foreach(b => ZkUtils.registerBrokerInZk(zkClient, b.id, b.host, b.port, jmxPort = -1))
+ brokers.foreach(b => ZkUtils.registerBrokerInZk(zkClient, b.id, b.host, b.port, 6000, jmxPort = -1))
brokers
}