root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

MINOR: Replace deprecated RichOptional.asScala with toScala (#18529) 

Reference: https://www.scala-lang.org/api/2.13.0/scala/jdk/OptionConverters$$RichOptional.html

Reviewers: Ismael Juma <ismael@juma.me.uk>
This commit is contained in:
TengYao Chi 2025-01-16 22:32:49 +08:00 committed by GitHub
parent 23c459286b
commit 724cf84de9
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/src/main/scala/kafka/server/metadata/KRaftMetadataCache.scala
View File

@ -380,7 +380,7 @@ class KRaftMetadataCache(
}
override def getBrokerNodes(listenerName: ListenerName): Seq[Node] = {
_currentImage.cluster().brokers().values().asScala.flatMap(_.node(listenerName.value()).asScala).toSeq
_currentImage.cluster().brokers().values().asScala.flatMap(_.node(listenerName.value()).toScala).toSeq
}
// Does NOT include offline replica metadata