DL1231 commented on code in PR #13947:
URL: https://github.com/apache/kafka/pull/13947#discussion_r1263161907
##########
core/src/main/scala/kafka/server/ReplicaManager.scala:
##########
@@ -500,11 +504,13 @@ class ReplicaManager(val config: KafkaConfig,
// Delete log and corresponding folders in case replica manager
doesn't hold them anymore.
// This could happen when topic is being deleted while broker is
down and recovers.
stoppedPartitions += topicPartition -> deletePartition
+ if (remoteLogManager.isDefined)
+ partitionsMaybeToDeleteRemote += topicPartition
Review Comment:
When the state of the partition is HostedPartition.None, it indicates that
the topic was deleted during broker down and recoveries. Therefore, it can be
directly added to 'partitionsMaybeToDeleteRemote'.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
