abbccdda commented on a change in pull request #10142:
URL: https://github.com/apache/kafka/pull/10142#discussion_r599787253
##
File path: core/src/main/scala/kafka/server/AutoTopicCreationManager.scala
##
@@ -166,7 +179,34 @@ class DefaultAutoTopicCreationManager(
deb
abbccdda commented on a change in pull request #10142:
URL: https://github.com/apache/kafka/pull/10142#discussion_r599962199
##
File path:
core/src/test/scala/unit/kafka/server/AutoTopicCreationManagerTest.scala
##
@@ -263,7 +263,7 @@ class AutoTopicCreationManagerTest {
abbccdda commented on a change in pull request #10142:
URL: https://github.com/apache/kafka/pull/10142#discussion_r606089230
##
File path:
core/src/test/scala/unit/kafka/server/AutoTopicCreationManagerTest.scala
##
@@ -219,6 +225,146 @@ class AutoTopicCreationManagerTest {
abbccdda commented on a change in pull request #10142:
URL: https://github.com/apache/kafka/pull/10142#discussion_r606870392
##
File path: core/src/main/scala/kafka/server/AutoTopicCreationManager.scala
##
@@ -156,17 +169,44 @@ class DefaultAutoTopicCreationManager(
.s