Skip to content

Commit

Permalink
[LI-HOTFIX] Log partition reassignment requests (#392)
Browse files Browse the repository at this point in the history
TICKET = N/A
LI_DESCRIPTION =
Currently, there are no logs to show the partition reassignment requests sent via
the AlterPartitionReassignments request.
This PR adds the log to make troubleshooting easier
EXIT_CRITERIA = N/A
  • Loading branch information
gitlw authored Sep 21, 2022
1 parent 81dd4a6 commit eee54a0
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions core/src/main/scala/kafka/controller/KafkaController.scala
Original file line number Diff line number Diff line change
Expand Up @@ -2252,6 +2252,7 @@ class KafkaController(val config: KafkaConfig,
if (!isActive) {
callback(Right(new ApiError(Errors.NOT_CONTROLLER)))
} else {
info(s"Processing API partition reassignments $reassignments")
val reassignmentResults = mutable.Map.empty[TopicPartition, ApiError]
val partitionsToReassign = mutable.Map.empty[TopicPartition, ReplicaAssignment]

Expand Down

0 comments on commit eee54a0

Please sign in to comment.