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
+
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