cmccabe commented on a change in pull request #10931: URL: https://github.com/apache/kafka/pull/10931#discussion_r663276540
########## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ########## @@ -2032,4 +2001,207 @@ class ReplicaManager(val config: KafkaConfig, } } + private[kafka] def getOrCreatePartition(tp: TopicPartition, + delta: TopicsDelta, + topicId: Uuid): Option[(Partition, Boolean)] = { + getPartition(tp) match { + case HostedPartition.Offline => + stateChangeLogger.warn(s"Unable to bring up new local leader ${tp} " + + s"with topic id ${topicId} because it resides in an offline log " + + "directory.") + None + + case HostedPartition.Online(partition) => Some(partition, false) Review comment: It's a bit messy because actually the topic ID is not stored in the Partition object, but in the Log object, which may not actually exist (although we'd want to transition out of online mode eventually if that were the case, of course.) I will add a check that if the id is defined it's correct, though. -- 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