[cleanup][misc] Add override annotation (#24033)

apache · Feb 28, 2025 · 6fc9b79 · 6fc9b79
1 parent efcf7c2
commit 6fc9b79
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/...ker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryImpl.java b/...ker/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
@@ -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) {