fix(core): compare topic id with equal (#870)

Signed-off-by: Shichao Nie <[email protected]>
AutoMQ · Mar 1, 2024 · 4a2c0a4 · 4a2c0a4
1 parent b50958e
commit 4a2c0a4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/metadata/src/main/java/org/apache/kafka/controller/ControllerMetricsManager.java b/metadata/src/main/java/org/apache/kafka/controller/ControllerMetricsManager.java
@@ -288,7 +288,7 @@ private void replay(PartitionChangeRecord record) {
 
     private void replay(RemoveTopicRecord record) {
         Uuid topicId = record.topicId();
-        Predicate<TopicIdPartition> matchesTopic = tp -> tp.topicId() == topicId;
+        Predicate<TopicIdPartition> matchesTopic = tp -> tp.topicId().equals(topicId);
 
         topicCount--;
         topicPartitions.keySet().removeIf(matchesTopic);