soarez commented on code in PR #14903:
URL: https://github.com/apache/kafka/pull/14903#discussion_r1415408700
##########
core/src/main/scala/kafka/server/BrokerLifecycleManager.scala:
##########
@@ -166,6 +166,19 @@ class BrokerLifecycleManager(
*/
private var registered = false
+ /**
+ * True if a request has been sent and a response or timeout has not yet
been processed.
Review Comment:
We do. The very first Registration request is also scheduled via a
`CommunicationEvent`.
`communicationInFlight = true` is now set after both
`_channelManager.sendRequest(new BrokerRegistrationRequest...` and
`_channelManager.sendRequest(new BrokerHeartbeatRequest...`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
