THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- Abstract the output of each state change input source to an event.
- Have a single execution thread to serially process events one at a time.
- The zk listeners are responsible for only context updating but not event execution.
- Use o.a.k.clients.NetworClient + callback for state change propagation.
We would also like to modify
- Modify KafkaServer to use new NetworkClient and prioritize the controller-to-broker traffic.
- Change the reads/writes to Zookeeper to maybe use multi-operation or async operation.
Related tickets
KAFKA-2139, KAFKA-2029, KAFKA-1305 (and definitely some other tickets... Appreciate it if people can add it here.)
...