server

Type Members

1. abstract class AbstractFetcherManager extends Logging with KafkaMetricsGroup

2. abstract class AbstractFetcherThread extends ShutdownableThread

   Abstract class for fetching data from multiple partitions from the same broker.

3. case class BrokerAndFetcherId(broker: Broker, fetcherId: Int) extends Product with Serializable

4. case class BrokerAndInitialOffset(broker: Broker, initOffset: Long) extends Product with Serializable

5. case class BrokerState() extends Product with Serializable

6. sealed trait BrokerStates extends AnyRef

   Broker states are the possible state that a kafka broker can be in.

7. class BrokerTopicMetrics extends KafkaMetricsGroup

8. case class ClientIdTopicPartition(clientId: String, topic: String, partitionId: Int) extends Product with Serializable

9. class DelayedFetch extends DelayedRequest

   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

10. class DelayedProduce extends DelayedRequest with Logging

    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.

11. case class DelayedProduceResponseStatus(requiredOffset: Long, responseStatus: ProducerResponseStatus) extends Product with Serializable

12. class DelayedRequest extends DelayedItem[Request]

    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.

13. case class FetchDataInfo(fetchOffset: LogOffsetMetadata, messageSet: MessageSet) extends Product with Serializable

14. class FetchRequestPurgatory extends RequestPurgatory[DelayedFetch]

    The purgatory holding delayed fetch requests

15. class FetcherLagMetrics extends KafkaMetricsGroup

16. class FetcherLagStats extends AnyRef

17. class FetcherStats extends KafkaMetricsGroup

18. case class GroupTopicPartition(group: String, topicPartition: TopicAndPartition) extends Product with Serializable

19. class KafkaApis extends Logging

    Logic to handle the various Kafka requests

20. class KafkaConfig extends ZKConfig

    Configuration settings for the kafka server

21. class KafkaHealthcheck extends Logging

    This class registers the broker in zookeeper to allow other brokers and consumers to detect failures.

22. class KafkaRequestHandler extends Runnable with Logging

    A thread that answers kafka requests.

23. class KafkaRequestHandlerPool extends Logging with KafkaMetricsGroup

24. class KafkaServer extends Logging with KafkaMetricsGroup

    Represents the lifecycle of a single Kafka broker.

25. class KafkaServerStartable extends Logging

26. trait LeaderElector extends Logging

    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

27. case class LogOffsetMetadata(messageOffset: Long, segmentBaseOffset: Long = ..., relativePositionInSegment: Int = ...) extends Product with Serializable

28. class OffsetCheckpoint extends Logging

    This class saves out a map of topic/partition=>offsets to a file

29. class OffsetManager extends Logging with KafkaMetricsGroup

30. case class OffsetManagerConfig(maxMetadataSize: Int = ..., loadBufferSize: Int = ..., offsetsRetentionMs: Long = 24.*(60).*(60000L), offsetsRetentionCheckIntervalMs: Long = ..., offsetsTopicNumPartitions: Int = ..., offsetsTopicSegmentBytes: Int = ..., offsetsTopicReplicationFactor: Short = ..., offsetsTopicCompressionCodec: CompressionCodec = ..., offsetCommitTimeoutMs: Int = ..., offsetCommitRequiredAcks: Short = ...) extends Product with Serializable

    Configuration settings for in-built offset management

31. case class PartitionDataAndOffset(data: FetchResponsePartitionData, offset: LogOffsetMetadata) extends Product with Serializable

32. class ProducerRequestPurgatory extends RequestPurgatory[DelayedProduce]

    The purgatory holding delayed producer requests

33. class ReplicaFetcherManager extends AbstractFetcherManager

34. class ReplicaFetcherThread extends AbstractFetcherThread

35. class ReplicaManager extends Logging with KafkaMetricsGroup

36. abstract class RequestPurgatory[T <: DelayedRequest] extends Logging with KafkaMetricsGroup

    A helper class for dealing with asynchronous requests with a timeout.

37. class TopicConfigManager extends Logging

    This class initiates and carries out topic config changes.

38. class ZookeeperLeaderElector extends LeaderElector with Logging

    This class handles zookeeper based leader election based on an ephemeral path.