fix debug msg

TaiJuWu · TaiJuWu · commit f1d62cb1cc52 · 2025-03-20T08:21:48.000Z
diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala b/core/src/main/scala/kafka/server/ReplicaManager.scala
@@ -1724,7 +1724,7 @@ class ReplicaManager(val config: KafkaConfig,
 
         if (preferredReadReplica.isDefined) {
           replicaSelectorPlugin.foreach { selector =>
-            debug(s"Replica selector plugin ${selector.getClass.getSimpleName} returned preferred replica " +
+            debug(s"Replica selector ${selector.get.getClass.getSimpleName} returned preferred replica " +
               s"${preferredReadReplica.get} for ${params.clientMetadata}")
           }
           // If a preferred read-replica is set, skip the read

Original file line number	Diff line number	Diff line change
`@@ -1724,7 +1724,7 @@ class ReplicaManager(val config: KafkaConfig,`
`1724`	`1724`
`1725`	`1725`	`if (preferredReadReplica.isDefined) {`
`1726`	`1726`	`replicaSelectorPlugin.foreach { selector =>`
`1727`		`- debug(s"Replica selector plugin ${selector.getClass.getSimpleName} returned preferred replica " +`
	`1727`	`+ debug(s"Replica selector ${selector.get.getClass.getSimpleName} returned preferred replica " +`
`1728`	`1728`	`s"${preferredReadReplica.get} for ${params.clientMetadata}")`
`1729`	`1729`	`}`
`1730`	`1730`	`// If a preferred read-replica is set, skip the read`