Browse Source

MINOR: Fix documentation for updateCurrentReassignment (#7611)

The function KafkaController.updateCurrentReassignment doesn't return any value. Fix the documentation to reflect that.
pull/7624/head
José Armando García Sancio 5 years ago committed by David Arthur
parent
commit
0dbf95b1c1
  1. 2
      core/src/main/scala/kafka/controller/KafkaController.scala

2
core/src/main/scala/kafka/controller/KafkaController.scala

@ -663,8 +663,6 @@ class KafkaController(val config: KafkaConfig, @@ -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)

Loading…
Cancel
Save