mumrah commented on code in PR #13975:
URL: https://github.com/apache/kafka/pull/13975#discussion_r1263821011


##########
core/src/main/scala/kafka/server/MetadataCache.scala:
##########
@@ -109,6 +109,8 @@ trait MetadataCache {
   def getRandomAliveBrokerId: Option[Int]
 
   def features(): Features
+
+  def isInitialized(): Boolean

Review Comment:
   Since KRaft brokers have the concept of fencing and metadata write requests 
are forwarded to the controller, this isn't really necessary. Can we make this 
method ZkMetadataCache-only?



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to