apache · abbccdda · Feb 6, 2021 · Nov 9, 2020 · Feb 5, 2021 · Feb 5, 2021
diff --git a/core/src/main/scala/kafka/server/AutoTopicCreationManager.scala b/core/src/main/scala/kafka/server/AutoTopicCreationManager.scala
@@ -169,6 +169,8 @@ class DefaultAutoTopicCreationManager(
         }
     }
 
+    clearInflightRequests(creatableTopics)
+
     creatableTopicResponses
   }
-Original file line number
+Diff line change
@@ Expand Up / @@ -169,6 +169,8 @@ class DefaultAutoTopicCreationManager( @@
             }
         }
+        clearInflightRequests(creatableTopics)
         creatableTopicResponses
       }
@@ Expand Down @@