kafka

api

package api

Visibility
  1. Public
  2. All

Type Members

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

  2. case class ConsumerMetadataResponse(coordinatorOpt: Option[Broker], errorCode: Short, correlationId: Int = 0) extends RequestOrResponse with Product with Serializable

  3. case class ControlledShutdownRequest(versionId: Short, correlationId: Int, brokerId: Int) extends RequestOrResponse with Product with Serializable

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

  5. 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

  6. class FetchRequestBuilder extends AnyRef

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

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

  9. class FetchResponseSend extends Send

  10. case class HeartbeatRequestAndHeader(versionId: Short, correlationId: Int, clientId: String, body: HeartbeatRequest) extends GenericRequestAndHeader with Product with Serializable

  11. case class HeartbeatResponseAndHeader(correlationId: Int, body: HeartbeatResponse) extends GenericResponseAndHeader with Product with Serializable

  12. case class JoinGroupRequestAndHeader(versionId: Short, correlationId: Int, clientId: String, body: JoinGroupRequest) extends GenericRequestAndHeader with Product with Serializable

  13. case class JoinGroupResponseAndHeader(correlationId: Int, body: JoinGroupResponse) extends GenericResponseAndHeader with Product with Serializable

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

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

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

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

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

    Single constructor for both version 0 and 1 since they have the same format.

  19. 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

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

  21. 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

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

  23. class PartitionDataSend extends Send

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

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

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

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

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

  29. 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

  30. case class ProducerResponse(correlationId: Int, status: Map[TopicAndPartition, ProducerResponseStatus]) extends RequestOrResponse with Product with Serializable

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

  32. abstract class RequestOrResponse extends Logging

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

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

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

  36. class TopicDataSend extends Send

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

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

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

  40. 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

  41. 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 ConsumerMetadataRequest extends Serializable

  3. object ConsumerMetadataResponse extends Serializable

  4. object ControlledShutdownRequest extends Logging with Serializable

  5. object ControlledShutdownResponse extends Serializable

  6. object FetchRequest extends Serializable

  7. object FetchResponse extends Serializable

  8. object FetchResponsePartitionData extends Serializable

  9. object HeartbeatRequestAndHeader extends Serializable

  10. object HeartbeatResponseAndHeader extends Serializable

  11. object JoinGroupRequestAndHeader extends Serializable

  12. object JoinGroupResponseAndHeader extends Serializable

  13. object LeaderAndIsr extends Serializable

  14. object LeaderAndIsrRequest extends Serializable

  15. object LeaderAndIsrResponse extends Serializable

  16. object OffsetCommitRequest extends Logging with Serializable

  17. object OffsetCommitResponse extends Logging with Serializable

  18. object OffsetFetchRequest extends Logging with Serializable

  19. object OffsetFetchResponse extends Logging with Serializable

  20. object OffsetRequest extends Serializable

  21. object OffsetResponse extends Serializable

  22. object PartitionMetadata extends Serializable

  23. object PartitionStateInfo extends Serializable

  24. object ProducerRequest extends Serializable

  25. object ProducerResponse extends Serializable

  26. object Request

  27. object RequestKeys

  28. object StopReplicaRequest extends Logging with Serializable

  29. object StopReplicaResponse extends Serializable

  30. object TopicData extends Serializable

  31. object TopicMetadata extends Serializable

  32. object TopicMetadataRequest extends Logging with Serializable

  33. object TopicMetadataResponse extends Serializable

  34. object UpdateMetadataRequest extends Serializable

  35. object UpdateMetadataResponse extends Serializable

Ungrouped