Description
KafkaController.isActive() is not synchronized right now. This means that it could read an outdated controllerContext.controllerChannelManager.
KafkaController.isActive() is not synchronized right now. This means that it could read an outdated controllerContext.controllerChannelManager.