Abstract class for fetching data from multiple partitions from the same broker.
Broker states are the possible state that a kafka broker can be in.
A delayed fetch request, which is satisfied (or more accurately, unblocked) -- if: Case A: This broker is no longer the leader for some partitions it tries to fetch
A delayed produce request, which is satisfied (or more accurately, unblocked) -- if for every partition it produce to: Case A: This broker is not the leader: unblock - should return error.
A request whose processing needs to be delayed for at most the given delayMs The associated keys are used for bookeeping, and represent the "trigger" that causes this request to check if it is satisfied, for example a key could be a (topic, partition) pair.
The purgatory holding delayed fetch requests
Logic to handle the various Kafka requests
Configuration settings for the kafka server
This class registers the broker in zookeeper to allow other brokers and consumers to detect failures.
A thread that answers kafka requests.
Represents the lifecycle of a single Kafka broker.
This trait defines a leader elector If the existing leader is dead, this class will handle automatic re-election and if it succeeds, it invokes the leader state change callback
This class saves out a map of topic/partition=>offsets to a file
Configuration settings for in-built offset management
The purgatory holding delayed producer requests
A helper class for dealing with asynchronous requests with a timeout.
This class initiates and carries out topic config changes.
This class handles zookeeper based leader election based on an ephemeral path.