From 0dbf95b1c1f4317fb2018d9852878aada6c01c32 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jos=C3=A9=20Armando=20Garc=C3=ADa=20Sancio?= Date: Wed, 30 Oct 2019 07:41:12 -0700 Subject: [PATCH] MINOR: Fix documentation for updateCurrentReassignment (#7611) The function KafkaController.updateCurrentReassignment doesn't return any value. Fix the documentation to reflect that. --- core/src/main/scala/kafka/controller/KafkaController.scala | 2 -- 1 file changed, 2 deletions(-) diff --git a/core/src/main/scala/kafka/controller/KafkaController.scala b/core/src/main/scala/kafka/controller/KafkaController.scala index 5456c62af6a..7b28202e6da 100644 --- a/core/src/main/scala/kafka/controller/KafkaController.scala +++ b/core/src/main/scala/kafka/controller/KafkaController.scala @@ -663,8 +663,6 @@ class KafkaController(val config: KafkaConfig, * * @param topicPartition The reassigning partition * @param reassignment The new reassignment - * - * @return The updated assignment state */ private def updateCurrentReassignment(topicPartition: TopicPartition, reassignment: ReplicaAssignment): Unit = { val currentAssignment = controllerContext.partitionFullReplicaAssignment(topicPartition)