fix typo

yahoo · Jun 29, 2015 · 1018c2c · 1018c2c
1 parent ac71562
commit 1018c2c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/app/kafka/manager/utils/AdminUtils.scala b/app/kafka/manager/utils/AdminUtils.scala
@@ -130,7 +130,7 @@ class AdminUtils(version: KafkaVersion) {
       checkCondition(curator.checkExists().forPath(topicPath) == null,TopicErrors.TopicAlreadyExists(topic))
     }
     partitionReplicaAssignment.foreach {
-      case (part,reps) => checkCondition(reps.size == reps.toSet.size, TopicErrors.DuplicateReplicAssignment(topic,part,reps))
+      case (part,reps) => checkCondition(reps.size == reps.toSet.size, TopicErrors.DuplicateReplicaAssignment(topic,part,reps))
     }
 
     // write out the config on create, not update, if there is any, this isn't transactional with the partition assignments

diff --git a/app/kafka/manager/utils/Topic.scala b/app/kafka/manager/utils/Topic.scala
@@ -77,7 +77,7 @@ object TopicErrors {
   def ReplicationGreaterThanNumBrokers(rf: Int, nb: Int) = new ReplicationGreaterThanNumBrokers(rf,nb)
   val InconsistentPartitionReplicas = new InconsistentPartitionReplicas
   def TopicAlreadyExists(topic: String) = new TopicAlreadyExists(topic)
-  def DuplicateReplicAssignment(topic: String, part: Int, replicas: Seq[Int]) = new DuplicateReplicaAssignment(topic,part,replicas)
+  def DuplicateReplicaAssignment(topic: String, part: Int, replicas: Seq[Int]) = new DuplicateReplicaAssignment(topic,part,replicas)
   def CannotAddZeroPartitions(topic: String, currentPartitions: Int, newPartitions:Int) = new CannotAddZeroPartitions(topic,currentPartitions,newPartitions)
   def FailedToAddNewPartitions(topic: String, newPartitions:Int, found: Int) = new FailedToAddNewPartitions(topic,newPartitions,found)
   def TopicDoesNotExist(topic: String) = new TopicDoesNotExist(topic)