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 <[email protected]> Authored: Mon Aug 5 13:23:55 2013 -0700 Committer: Neha Narkhede <[email protected]> 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 }
