Return-Path: X-Original-To: apmail-kafka-commits-archive@www.apache.org Delivered-To: apmail-kafka-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 67C77C198 for ; Mon, 5 Aug 2013 20:24:08 +0000 (UTC) Received: (qmail 6002 invoked by uid 500); 5 Aug 2013 20:24:08 -0000 Delivered-To: apmail-kafka-commits-archive@kafka.apache.org Received: (qmail 5957 invoked by uid 500); 5 Aug 2013 20:24:07 -0000 Mailing-List: contact commits-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list commits@kafka.apache.org Received: (qmail 5946 invoked by uid 99); 5 Aug 2013 20:24:07 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 05 Aug 2013 20:24:07 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 3E9BD8B93A9; Mon, 5 Aug 2013 20:24:07 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: nehanarkhede@apache.org To: commits@kafka.apache.org Message-Id: <1643c352a5ae4ae3b1caa87c8718c2be@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: git commit: KAFKA-992 follow up. Fix broken unit test Date: Mon, 5 Aug 2013 20:24:07 +0000 (UTC) Updated Branches: refs/heads/0.8 14af71325 -> 7fbbb6666 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/0.8 Commit: 7fbbb6666bef10f31301c4af17a6077e8895fa06 Parents: 14af713 Author: Neha Narkhede Authored: Mon Aug 5 13:23:55 2013 -0700 Committer: Neha Narkhede 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 }