kafka

api

package api

Visibility
  1. Public
  2. All

Type Members

  1. sealed trait ApiVersion extends Ordered[ApiVersion]

  2. case class ControlledShutdownRequest(versionId: Short, correlationId: Int, clientId: Option[String], brokerId: Int) extends RequestOrResponse with Product with Serializable

  3. case class ControlledShutdownResponse(correlationId: Int, errorCode: Short = kafka.common.ErrorMapping.NoError, partitionsRemaining: Set[TopicAndPartition]) extends RequestOrResponse with Product with Serializable

  4. case class FetchRequest(versionId: Short = FetchRequest.CurrentVersion, correlationId: Int = FetchRequest.DefaultCorrelationId, clientId: String = ..., replicaId: Int = Request.OrdinaryConsumerId, maxWait: Int = FetchRequest.DefaultMaxWait, minBytes: Int = FetchRequest.DefaultMinBytes, requestInfo: Map[TopicAndPartition, PartitionFetchInfo]) extends RequestOrResponse with Product with Serializable

  5. class FetchRequestBuilder extends AnyRef

    Annotations
    @nonthreadsafe()
  6. case class FetchResponse(correlationId: Int, data: Map[TopicAndPartition, FetchResponsePartitionData], requestVersion: Int = 0, throttleTimeMs: Int = 0) extends RequestOrResponse with Product with Serializable

  7. case class FetchResponsePartitionData(error: Short = kafka.common.ErrorMapping.NoError, hw: Long = -1L, messages: MessageSet) extends Product with Serializable

  8. class FetchResponseSend extends Send

  9. case class GroupCoordinatorRequest(group: String, versionId: Short = ..., correlationId: Int = 0, clientId: String = ...) extends RequestOrResponse with Product with Serializable

  10. case class GroupCoordinatorResponse(coordinatorOpt: Option[BrokerEndPoint], errorCode: Short, correlationId: Int) extends RequestOrResponse with Product with Serializable

  11. case class LeaderAndIsr(leader: Int, leaderEpoch: Int, isr: List[Int], zkVersion: Int) extends Product with Serializable

  12. case class LeaderAndIsrRequest(versionId: Short, correlationId: Int, clientId: String, controllerId: Int, controllerEpoch: Int, partitionStateInfos: Map[(String, Int), PartitionStateInfo], leaders: Set[BrokerEndPoint]) extends RequestOrResponse with Product with Serializable

  13. case class LeaderAndIsrResponse(correlationId: Int, responseMap: Map[(String, Int), Short], errorCode: Short = kafka.common.ErrorMapping.NoError) extends RequestOrResponse with Product with Serializable

  14. case class OffsetCommitRequest(groupId: String, requestInfo: Map[TopicAndPartition, OffsetAndMetadata], versionId: Short = OffsetCommitRequest.CurrentVersion, correlationId: Int = 0, clientId: String = OffsetCommitRequest.DefaultClientId, groupGenerationId: Int = ..., memberId: String = ..., retentionMs: Long = ...) extends RequestOrResponse with Product with Serializable

  15. case class OffsetCommitResponse(commitStatus: Map[TopicAndPartition, Short], correlationId: Int = 0) extends RequestOrResponse with Product with Serializable

  16. case class OffsetFetchRequest(groupId: String, requestInfo: Seq[TopicAndPartition], versionId: Short = OffsetFetchRequest.CurrentVersion, correlationId: Int = 0, clientId: String = OffsetFetchRequest.DefaultClientId) extends RequestOrResponse with Product with Serializable

  17. case class OffsetFetchResponse(requestInfo: Map[TopicAndPartition, OffsetMetadataAndError], correlationId: Int = 0) extends RequestOrResponse with Product with Serializable

  18. case class OffsetRequest(requestInfo: Map[TopicAndPartition, PartitionOffsetRequestInfo], versionId: Short = OffsetRequest.CurrentVersion, correlationId: Int = 0, clientId: String = OffsetRequest.DefaultClientId, replicaId: Int = Request.OrdinaryConsumerId) extends RequestOrResponse with Product with Serializable

  19. case class OffsetResponse(correlationId: Int, partitionErrorAndOffsets: Map[TopicAndPartition, PartitionOffsetsResponse]) extends RequestOrResponse with Product with Serializable

  20. class PartitionDataSend extends Send

  21. case class PartitionFetchInfo(offset: Long, fetchSize: Int) extends Product with Serializable

  22. case class PartitionMetadata(partitionId: Int, leader: Option[BrokerEndPoint], replicas: Seq[BrokerEndPoint], isr: Seq[BrokerEndPoint] = collection.this.Seq.empty[Nothing], errorCode: Short = kafka.common.ErrorMapping.NoError) extends Logging with Product with Serializable

  23. case class PartitionOffsetRequestInfo(time: Long, maxNumOffsets: Int) extends Product with Serializable

  24. case class PartitionOffsetsResponse(error: Short, offsets: Seq[Long]) extends Product with Serializable

  25. case class PartitionStateInfo(leaderIsrAndControllerEpoch: LeaderIsrAndControllerEpoch, allReplicas: Set[Int]) extends Product with Serializable

  26. case class ProducerRequest(versionId: Short = ProducerRequest.CurrentVersion, correlationId: Int, clientId: String, requiredAcks: Short, ackTimeoutMs: Int, data: Map[TopicAndPartition, ByteBufferMessageSet]) extends RequestOrResponse with Product with Serializable

  27. case class ProducerResponse(correlationId: Int, status: Map[TopicAndPartition, ProducerResponseStatus], requestVersion: Int = 0, throttleTime: Int = 0) extends RequestOrResponse with Product with Serializable

  28. case class ProducerResponseStatus(error: Short, offset: Long) extends Product with Serializable

  29. abstract class RequestOrResponse extends Logging

  30. case class StopReplicaRequest(versionId: Short, correlationId: Int, clientId: String, controllerId: Int, controllerEpoch: Int, deletePartitions: Boolean, partitions: Set[TopicAndPartition]) extends RequestOrResponse with Product with Serializable

  31. case class StopReplicaResponse(correlationId: Int, responseMap: Map[TopicAndPartition, Short], errorCode: Short = kafka.common.ErrorMapping.NoError) extends RequestOrResponse with Product with Serializable

  32. case class TopicData(topic: String, partitionData: Map[Int, FetchResponsePartitionData]) extends Product with Serializable

  33. class TopicDataSend extends Send

  34. case class TopicMetadata(topic: String, partitionsMetadata: Seq[PartitionMetadata], errorCode: Short = kafka.common.ErrorMapping.NoError) extends Logging with Product with Serializable

  35. case class TopicMetadataRequest(versionId: Short, correlationId: Int, clientId: String, topics: Seq[String]) extends RequestOrResponse with Product with Serializable

  36. case class TopicMetadataResponse(brokers: Seq[BrokerEndPoint], topicsMetadata: Seq[TopicMetadata], correlationId: Int) extends RequestOrResponse with Product with Serializable

  37. case class UpdateMetadataRequest(versionId: Short, correlationId: Int, clientId: String, controllerId: Int, controllerEpoch: Int, partitionStateInfos: Map[TopicAndPartition, PartitionStateInfo], aliveBrokers: Set[Broker]) extends RequestOrResponse with Product with Serializable

  38. case class UpdateMetadataResponse(correlationId: Int, errorCode: Short = kafka.common.ErrorMapping.NoError) extends RequestOrResponse with Product with Serializable

Value Members

  1. object ApiUtils

    Helper functions specific to parsing or serializing requests and responses

  2. object ApiVersion

    This class contains the different Kafka versions.

  3. object ControlledShutdownRequest extends Logging with Serializable

  4. object ControlledShutdownResponse extends Serializable

  5. object FetchRequest extends Serializable

  6. object FetchResponse extends Serializable

  7. object FetchResponsePartitionData extends Serializable

  8. object GroupCoordinatorRequest extends Serializable

  9. object GroupCoordinatorResponse extends Serializable

  10. object KAFKA_080 extends ApiVersion with Product with Serializable

  11. object KAFKA_081 extends ApiVersion with Product with Serializable

  12. object KAFKA_082 extends ApiVersion with Product with Serializable

  13. object KAFKA_090 extends ApiVersion with Product with Serializable

  14. object LeaderAndIsr extends Serializable

  15. object LeaderAndIsrRequest extends Serializable

  16. object LeaderAndIsrResponse extends Serializable

  17. object OffsetCommitRequest extends Logging with Serializable

  18. object OffsetCommitResponse extends Logging with Serializable

  19. object OffsetFetchRequest extends Logging with Serializable

  20. object OffsetFetchResponse extends Logging with Serializable

  21. object OffsetRequest extends Serializable

  22. object OffsetResponse extends Serializable

  23. object PartitionMetadata extends Serializable

  24. object PartitionStateInfo extends Serializable

  25. object ProducerRequest extends Serializable

  26. object ProducerResponse extends Serializable

  27. object Request

  28. object RequestKeys

  29. object StopReplicaRequest extends Logging with Serializable

  30. object StopReplicaResponse extends Serializable

  31. object TopicData extends Serializable

  32. object TopicMetadata extends Serializable

  33. object TopicMetadataRequest extends Logging with Serializable

  34. object TopicMetadataResponse extends Serializable

  35. object UpdateMetadataRequest extends Serializable

  36. object UpdateMetadataResponse extends Serializable

Ungrouped