ijuma commented on code in PR #13390:
URL: https://github.com/apache/kafka/pull/13390#discussion_r1135739560
##
core/src/main/scala/kafka/server/BrokerLifecycleManager.scala:
##
@@ -182,7 +182,7 @@ class BrokerLifecycleManager(
*/
private[server] val eventQueue = new Kafk
ijuma commented on code in PR #13390:
URL: https://github.com/apache/kafka/pull/13390#discussion_r1135739560
##
core/src/main/scala/kafka/server/BrokerLifecycleManager.scala:
##
@@ -182,7 +182,7 @@ class BrokerLifecycleManager(
*/
private[server] val eventQueue = new Kafk
ijuma commented on code in PR #13390:
URL: https://github.com/apache/kafka/pull/13390#discussion_r1135736972
##
core/src/main/scala/kafka/server/ControllerServer.scala:
##
@@ -131,11 +131,11 @@ class ControllerServer(
if (!maybeChangeStatus(SHUTDOWN, STARTING)) return
ijuma commented on code in PR #13390:
URL: https://github.com/apache/kafka/pull/13390#discussion_r1135641916
##
core/src/main/scala/kafka/server/BrokerLifecycleManager.scala:
##
@@ -182,7 +182,7 @@ class BrokerLifecycleManager(
*/
private[server] val eventQueue = new Kafk
ijuma commented on code in PR #13390:
URL: https://github.com/apache/kafka/pull/13390#discussion_r1135641916
##
core/src/main/scala/kafka/server/BrokerLifecycleManager.scala:
##
@@ -182,7 +182,7 @@ class BrokerLifecycleManager(
*/
private[server] val eventQueue = new Kafk