[fix][broker] Fix typos lister -> listener (apache#21068)

(cherry picked from commit e0c481e)
(cherry picked from commit 9b13730)

pulsar-broker-common/src/test/java/org/apache/pulsar/broker/web/plugin/servlet/AdditionalServletUtilsTest.java

@@ -68,7 +68,7 @@ public void testLoadEventListener() throws Exception {
     }
 
     @Test(expectedExceptions = IOException.class)
-    public void testLoadEventListenerWithBlankListerClass() throws Exception {
+    public void testLoadEventListenerWithBlankListenerClass() throws Exception {
         AdditionalServletDefinition def = new AdditionalServletDefinition();
         def.setDescription("test-proxy-listener");
 
@@ -95,7 +95,7 @@ public void testLoadEventListenerWithBlankListerClass() throws Exception {
     }
 
     @Test(expectedExceptions = IOException.class)
-    public void testLoadEventListenerWithWrongListerClass() throws Exception {
+    public void testLoadEventListenerWithWrongListenerClass() throws Exception {
         AdditionalServletDefinition def = new AdditionalServletDefinition();
         def.setAdditionalServletClass(Runnable.class.getName());
         def.setDescription("test-proxy-listener");

pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java

@@ -1236,7 +1236,7 @@ public void onNamespaceBundleUnload(NamespaceBundle bundle) {
                     bundleOwnedListener.unLoad(bundle);
                 }
             } catch (Throwable t) {
-                LOG.error("Call bundle {} ownership lister error", bundle, t);
+                LOG.error("Call bundle {} ownership listener error", bundle, t);
             }
         }
     }
@@ -1259,7 +1259,7 @@ private void notifyNamespaceBundleOwnershipListener(NamespaceBundle bundle,
                         listener.onLoad(bundle);
                     }
                 } catch (Throwable t) {
-                    LOG.error("Call bundle {} ownership lister error", bundle, t);
+                    LOG.error("Call bundle {} ownership listener error", bundle, t);
                 }
             }
         }

pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/BrokerInterceptorUtilsTest.java

@@ -71,7 +71,7 @@ public void testLoadBrokerEventListener() throws Exception {
     }
 
     @Test(expectedExceptions = IOException.class)
-    public void testLoadBrokerEventListenerWithBlankListerClass() throws Exception {
+    public void testLoadBrokerEventListenerWithBlankListenerClass() throws Exception {
         BrokerInterceptorDefinition def = new BrokerInterceptorDefinition();
         def.setDescription("test-broker-listener");
 
@@ -98,7 +98,7 @@ public void testLoadBrokerEventListenerWithBlankListerClass() throws Exception {
     }
 
     @Test(expectedExceptions = IOException.class)
-    public void testLoadBrokerEventListenerWithWrongListerClass() throws Exception {
+    public void testLoadBrokerEventListenerWithWrongListenerClass() throws Exception {
         BrokerInterceptorDefinition def = new BrokerInterceptorDefinition();
         def.setInterceptorClass(Runnable.class.getName());
         def.setDescription("test-broker-listener");

pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java

@@ -228,7 +228,7 @@ protected void expectMoreIncomingMessages() {
         }
     }
 
-    // if lister is not null, we will track unAcked msg in callMessageListener
+    // if listener is not null, we will track unAcked msg in callMessageListener
     protected void trackUnAckedMsgIfNoListener(MessageId messageId, int redeliveryCount) {
         if (listener == null) {
             unAckedMessageTracker.add(messageId, redeliveryCount);

pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java

@@ -175,7 +175,7 @@ public CompletableFuture<Void> handleMetadataEvent(MetadataEvent event) {
         return result;
     }
 
-    protected void registerSyncLister(Optional<MetadataEventSynchronizer> synchronizer) {
+    protected void registerSyncListener(Optional<MetadataEventSynchronizer> synchronizer) {
         synchronizer.ifPresent(s -> s.registerSyncListener(this::handleMetadataEvent));
     }
 

pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/LocalMemoryMetadataStore.java

@@ -83,7 +83,7 @@ public LocalMemoryMetadataStore(String metadataURL, MetadataStoreConfig metadata
         // Local means a private data set
         // update synchronizer and register sync listener
         synchronizer = metadataStoreConfig.getSynchronizer();
-        registerSyncLister(Optional.ofNullable(synchronizer));
+        registerSyncListener(Optional.ofNullable(synchronizer));
         if ("local".equals(name)) {
             map = new TreeMap<>();
             sequentialIdGenerator = new AtomicLong();

pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/RocksdbMetadataStore.java

@@ -113,7 +113,7 @@ public static RocksdbMetadataStore get(String metadataStoreUri, MetadataStoreCon
         store = new RocksdbMetadataStore(metadataStoreUri, conf);
         // update synchronizer and register sync listener
         store.synchronizer = conf.getSynchronizer();
-        store.registerSyncLister(Optional.ofNullable(store.synchronizer));
+        store.registerSyncListener(Optional.ofNullable(store.synchronizer));
         instancesCache.put(metadataStoreUri, store);
         return store;
     }

pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java

@@ -76,7 +76,7 @@ protected AbstractBatchedMetadataStore(MetadataStoreConfig conf) {
 
         // update synchronizer and register sync listener
         synchronizer = conf.getSynchronizer();
-        registerSyncLister(Optional.ofNullable(synchronizer));
+        registerSyncListener(Optional.ofNullable(synchronizer));
         this.batchMetadataStoreStats =
                 new BatchMetadataStoreStats(metadataStoreName, executor);
     }