Bulk Operation

KAFKA-5027 batch LeaderAndIsr requests during auto preferred leader election

KAFKA-5027 KafkaZkClient request queue time metric

KAFKA-5027 move ZK metrics in KafkaHealthCheck to ZookeeperClient

KAFKA-5027 minimize the number of triggers enqueuing PreferredReplicaLeaderElection events

KAFKA-5027 Tests for KafkaZkClient

KAFKA-5027 consider fencing zookeeper updates with controller epoch zkVersion

KAFKA-5027 response error code checking

KAFKA-5027 Use ZookeeperClient in ReplicaManager and Partition

KAFKA-5027 Use ZookeeperClient in KafkaApis

KAFKA-5027 Use ZookeeperClient in GroupCoordinator and TransactionCoordinator

KAFKA-5027 Use ZookeeperClient in LogManager

KAFKA-5027 Add ZooKeeperRequestLatencyMs to KafkaZkClient

KAFKA-5027 Controller should wait for the leader migration to finish before ack a ControlledShutdownRequest

KAFKA-5027 add the notion of max inflight requests to async ZookeeperClient

KAFKA-5027 Use async ZookeeperClient for Admin operations

KAFKA-5027 Use async ZookeeperClient for DynamicConfigManager

KAFKA-5027 Use async ZookeeperClient in SimpleAclAuthorizer

KAFKA-5027 Use async ZookeeperClient in Controller

KAFKA-5027 read current brokers from zookeeper upon processing broker change

KAFKA-5027 introduce async ZookeeperClient

KAFKA-5027 handle ZK session expiration properly when a new session can't be established

KAFKA-5027 consider switching json parser from scala to jackson

KAFKA-5027 reset ControllerContext during resignation

KAFKA-5027 move all partition and replica state transition rules into their states

KAFKA-5027 add a tool analyzing zookeeper client performance across its various apis

KAFKA-5027 remove preferred replica election state from ControllerContext

KAFKA-5027 always leave the last surviving member of the ISR in ZK

KAFKA-5027 add controller integration tests

KAFKA-5027 cleanup javadocs and logging

KAFKA-5027 convert kafka controller to a single-threaded event queue model

KAFKA-5027 Controller could miss a broker state change