kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jjko...@apache.org
Subject git commit: Trivial: update javadoc comment for KAFKA-1355
Date Tue, 08 Apr 2014 18:14:46 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 0e1d853c0 -> 69655d5fb


Trivial: update javadoc comment for KAFKA-1355


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/69655d5f
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/69655d5f
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/69655d5f

Branch: refs/heads/trunk
Commit: 69655d5fb92ea7e15ebcbfbe345bea9fe04f69d1
Parents: 0e1d853
Author: Joel Koshy <jjkoshy@gmail.com>
Authored: Tue Apr 8 11:14:35 2014 -0700
Committer: Joel Koshy <jjkoshy@gmail.com>
Committed: Tue Apr 8 11:14:35 2014 -0700

----------------------------------------------------------------------
 .../main/scala/kafka/controller/ControllerChannelManager.scala   | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/69655d5f/core/src/main/scala/kafka/controller/ControllerChannelManager.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/controller/ControllerChannelManager.scala b/core/src/main/scala/kafka/controller/ControllerChannelManager.scala
index f79c1dc..c95c650 100644
--- a/core/src/main/scala/kafka/controller/ControllerChannelManager.scala
+++ b/core/src/main/scala/kafka/controller/ControllerChannelManager.scala
@@ -229,9 +229,7 @@ class ControllerBrokerRequestBatch(controller: KafkaController) extends
 Logging
     }
   }
 
-  /* Send UpdateMetadataRequest to the given brokers for all partitions except those being
deleted as part of delete topic
-   *
-   */
+  /** Send UpdateMetadataRequest to the given brokers for the given partitions and partitions
that are being deleted */
   def addUpdateMetadataRequestForBrokers(brokerIds: Seq[Int],
                                          partitions: collection.Set[TopicAndPartition] =
Set.empty[TopicAndPartition],
                                          callback: (RequestOrResponse) => Unit = null)
{


Mime
View raw message