DL1231 commented on code in PR #13947:
URL: https://github.com/apache/kafka/pull/13947#discussion_r1264591381
##########
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:
Thank you for the explanation, here will additionally verify the
`requestLeaderEpoch` information.
--
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
