[GitHub] [kafka] showuon commented on a diff in pull request #14051: KAFKA-15218: Avoid NPE thrown while deleting topic and fetch from follower concurrently

showuon commented on code in PR #14051: URL: https://github.com/apache/kafka/pull/14051#discussion_r1271666143 ## core/src/test/scala/unit/kafka/cluster/PartitionTest.scala: ## @@ -1290,6 +1290,56 @@ class PartitionTest extends AbstractPartitionTest { ) } + @Test +

[GitHub] [kafka] showuon commented on a diff in pull request #14051: KAFKA-15218: Avoid NPE thrown while deleting topic and fetch from follower concurrently

showuon commented on code in PR #14051: URL: https://github.com/apache/kafka/pull/14051#discussion_r1268862349 ## core/src/main/scala/kafka/cluster/Partition.scala: ## @@ -998,7 +998,13 @@ class Partition(val topicPartition: TopicPartition, // 3. Its metadata cached