(pulsar) 01/03: [cleanup][misc] Add override annotation (#24033)

[lhotari]

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit 7d8c88002f01f34e58db199945466be5051d525a
Author: 3pacccccc <36988878+3paccc...@users.noreply.github.com>
AuthorDate: Fri Feb 28 16:43:47 2025 +0800

    [cleanup][misc] Add override annotation (#24033)
    
    (cherry picked from commit 6fc9b79f01560d22c3fd41ec2ab6fc70f61d0f16)
---
 .../apache/pulsar/broker/loadbalance/extensions/BrokerRegistryImpl.java | 2 ++
 .../src/main/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 18e30ddf922..45dfeb613b5 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
@@ -160,6 +160,7 @@ public class BrokerRegistryImpl implements BrokerRegistry {
         return brokerLookupDataLockManager.readLock(keyPath(broker));
     }
 
+    @Override
     public CompletableFuture<Map<String, BrokerLookupData>> 
getAvailableBrokerLookupDataAsync() {
         this.checkState();
         return this.getAvailableBrokersAsync().thenCompose(availableBrokers -> 
{
@@ -178,6 +179,7 @@ public class BrokerRegistryImpl implements BrokerRegistry {
         });
     }
 
+    @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 6d85e7513cc..00b3f41c74b 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
@@ -1110,7 +1110,7 @@ public class BrokerService implements Closeable {
                             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) {