THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block |
|---|
coordinatorStartup : 1. Read all the topics from ZK and initialize the interested groups for each topic and the list of groups with wildcard interests 2. Register listeners for topics and their partition changes 2.1 Subscribe TopicChangeListener to /brokers/topics 2.2 Subscribe TopicPartitionChangeListener to each /brokers/topics/[topic] 43. Start up the socket server and the scheduler for ping requests 54. Register session expiration listener 65. Initialize the threadpool of rebalancing hanldershandlers |
The scheduler for ping requests is a delayed scheduler, using a priority queue of timestamps to keep track of the outstanding list of PingRequest, whenever it sends a request it needs to initialize an expire watcher for the request.
...