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)
