We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f2dcf36 commit 7cd1511Copy full SHA for 7cd1511
core/src/main/scala/kafka/server/metadata/KRaftMetadataCache.scala
@@ -380,7 +380,7 @@ class KRaftMetadataCache(
380
}
381
382
override def getBrokerNodes(listenerName: ListenerName): Seq[Node] = {
383
- _currentImage.cluster().brokers().values().asScala.flatMap(_.node(listenerName.value()).asScala).toSeq
+ _currentImage.cluster().brokers().values().asScala.flatMap(_.node(listenerName.value()).toScala).toSeq
384
385
386
// Does NOT include offline replica metadata
0 commit comments