(kafka) branch trunk updated: MINOR: Migrate usage of deprecated Endpoint#listenerName() to Endpoint#listener() (#19825)

[frankvicky]

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

frankvicky pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new fafc140c836 MINOR: Migrate usage of deprecated Endpoint#listenerName() 
to Endpoint#listener() (#19825)
fafc140c836 is described below

commit fafc140c8360809bd24c7d3c738bef19febb9d39
Author: Ming-Yen Chung <mingyen...@gmail.com>
AuthorDate: Wed May 28 11:12:43 2025 +0800

    MINOR: Migrate usage of deprecated Endpoint#listenerName() to 
Endpoint#listener() (#19825)
    
    [KIP-1143](https://cwiki.apache.org/confluence/x/LwqWF) replaced
    `Optional<String> listenerName()` with `String listener()`.
    
    This patch migrates the usage from the deprecated method to the new one.
    
    Reviewers: Kuan-Po Tseng <brandb...@gmail.com>, Chia-Ping Tsai
     <chia7...@gmail.com>, Yung <yungyung7654...@gmail.com>, TengYao Chi
     <frankvi...@apache.org>, Ken Huang <s7133...@gmail.com>
---
 core/src/main/scala/kafka/server/BrokerServer.scala | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/core/src/main/scala/kafka/server/BrokerServer.scala 
b/core/src/main/scala/kafka/server/BrokerServer.scala
index 61892ea66c3..22749f1f4af 100644
--- a/core/src/main/scala/kafka/server/BrokerServer.scala
+++ b/core/src/main/scala/kafka/server/BrokerServer.scala
@@ -701,10 +701,7 @@ class BrokerServer(
       val listenerName = 
config.remoteLogManagerConfig.remoteLogMetadataManagerListenerName()
       val endpoint = if (listenerName != null) {
         Some(listenerInfo.listeners().values().stream
-          .filter(e =>
-            e.listenerName().isPresent &&
-              
ListenerName.normalised(e.listenerName().get()).equals(ListenerName.normalised(listenerName))
-          )
+          .filter(e => 
ListenerName.normalised(e.listener()).equals(ListenerName.normalised(listenerName)))
           .findFirst()
           .orElseThrow(() => new 
ConfigException(RemoteLogManagerConfig.REMOTE_LOG_METADATA_MANAGER_LISTENER_NAME_PROP,
             listenerName, "Should be set as a listener name within valid 
broker listener name list: " + listenerInfo.listeners().values())))