[jira] [Created] (KAFKA-3761) Controller has RunningAsBroker instead of RunningAsController state

["Ismael Juma (JIRA)" <ji...@apache.org>]

Ismael Juma created KAFKA-3761:
----------------------------------

             Summary: Controller has RunningAsBroker instead of RunningAsController state
                 Key: KAFKA-3761
                 URL: https://issues.apache.org/jira/browse/KAFKA-3761
             Project: Kafka
          Issue Type: Bug
            Reporter: Ismael Juma
            Assignee: Roger Hoover


In `KafkaServer.start`, we start `KafkaController`:

{code}
/* start kafka controller */
kafkaController = new KafkaController(config, zkUtils, brokerState, kafkaMetricsTime, metrics, threadNamePrefix)
kafkaController.startup()
{code}

Which sets the state to `RunningAsController` in `KafkaController.onControllerFailover`:

`brokerState.newState(RunningAsController)`

And this later gets set to `RunningAsBroker`.

This doesn't match the diagram in `BrokerStates`. [~junrao] suggested that we should start the controller after we register the broker in ZK, but this seems tricky as we need to controller in `KafkaApis`.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)