[GitHub] [kafka] ijuma commented on a change in pull request #10252: KAFKA-12403; Ensure local state deleted on `RemoveTopicRecord` received

2021-03-04 Thread GitBox
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

[GitHub] [kafka] ijuma commented on a change in pull request #10252: KAFKA-12403; Ensure local state deleted on `RemoveTopicRecord` received

2021-03-03 Thread GitBox
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

[GitHub] [kafka] ijuma commented on a change in pull request #10252: KAFKA-12403; Ensure local state deleted on `RemoveTopicRecord` received

2021-03-03 Thread GitBox
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,