From 6fc9b79f01560d22c3fd41ec2ab6fc70f61d0f16 Mon Sep 17 00:00:00 2001
From: 3pacccccc <36988878+3pacccccc@users.noreply.github.com>
Date: Fri, 28 Feb 2025 16:43:47 +0800
Subject: [PATCH] [cleanup][misc] Add override annotation (#24033)

---
 .../broker/loadbalance/extensions/BrokerRegistryImpl.java       | 2 ++
 .../java/org/apache/pulsar/broker/service/BrokerService.java    | 2 +-
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryImpl.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryImpl.java
index 5a8307df27a63..115bbe56ffa35 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryImpl.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryImpl.java
@@ -206,6 +206,7 @@ public CompletableFuture<Optional<BrokerLookupData>> lookupAsync(String broker)
         return brokerLookupDataMetadataCache.get(keyPath(broker));
     }
 
+    @Override
     public CompletableFuture<Map<String, BrokerLookupData>> getAvailableBrokerLookupDataAsync() {
         this.checkState();
         return this.getAvailableBrokersAsync().thenCompose(availableBrokers -> {
@@ -224,6 +225,7 @@ public CompletableFuture<Map<String, BrokerLookupData>> getAvailableBrokerLookup
         });
     }
 
+    @Override
     public synchronized void addListener(BiConsumer<String, NotificationType> listener) {
         this.checkState();
         this.listeners.add(listener);
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
index 3812d03f72b07..107bb01ffa0ce 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
@@ -1111,7 +1111,7 @@ public CompletableFuture<Optional<Topic>> getTopic(final TopicName topicName, bo
                             final TopicName topicNameEntity = TopicName.get(topicName.getPartitionedTopicName());
                             return fetchPartitionedTopicMetadataAsync(topicNameEntity)
                                     .thenCompose((metadata) -> {
-                                        // Allow crate non-partitioned persistent topic that name includes
+                                        // Allow creating non-partitioned persistent topic that name includes
                                         // `partition`
                                         if (metadata.partitions == 0
                                                 || topicName.getPartitionIndex() < metadata.partitions) {