ijuma commented on a change in pull request #10252:
URL: https://github.com/apache/kafka/pull/10252#discussion_r587677099
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -483,7 +475,7 @@ private ApiError createTopic(Creatab
ijuma commented on a change in pull request #10252:
URL: https://github.com/apache/kafka/pull/10252#discussion_r587128413
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -483,7 +475,7 @@ private ApiError createTopic(Creatab
ijuma commented on a change in pull request #10252:
URL: https://github.com/apache/kafka/pull/10252#discussion_r587126260
##
File path:
core/src/main/scala/kafka/server/metadata/BrokerMetadataListener.scala
##
@@ -142,28 +145,19 @@ class BrokerMetadataListener(brokerId: Int,