api

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 = 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 = ConsumerConfig.DefaultClientId, 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 = 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 = 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] = Seq.empty, errorCode: Short = 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 = 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 = 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 = ErrorMapping.NoError) extends RequestOrResponse with Product with Serializable