package
api
Type Members
-
-
case class
ControlledShutdownRequest(versionId: Short, correlationId: Int, clientId: Option[String], brokerId: Int) extends RequestOrResponse with Product with Serializable
-
-
-
-
-
-
-
case class
GroupCoordinatorRequest(group: String, versionId: Short = ..., correlationId: Int = 0, clientId: String = ...) extends RequestOrResponse with Product with Serializable
-
case class
GroupCoordinatorResponse(coordinatorOpt: Option[BrokerEndPoint], errorCode: Short, correlationId: Int) extends RequestOrResponse with Product with Serializable
-
case class
LeaderAndIsr(leader: Int, leaderEpoch: Int, isr: List[Int], zkVersion: Int) extends Product with Serializable
-
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
-
case class
LeaderAndIsrResponse(correlationId: Int, responseMap: Map[(String, Int), Short], errorCode: Short = ErrorMapping.NoError) extends RequestOrResponse with Product with Serializable
-
-
-
-
-
-
-
-
case class
PartitionFetchInfo(offset: Long, fetchSize: Int) extends Product with Serializable
-
-
case class
PartitionOffsetRequestInfo(time: Long, maxNumOffsets: Int) extends Product with Serializable
-
case class
PartitionOffsetsResponse(error: Short, offsets: Seq[Long]) extends Product with Serializable
-
case class
PartitionStateInfo(leaderIsrAndControllerEpoch: LeaderIsrAndControllerEpoch, allReplicas: Set[Int]) extends Product with Serializable
-
-
-
case class
ProducerResponseStatus(error: Short, offset: Long) extends Product with Serializable
-
-
case class
StopReplicaRequest(versionId: Short, correlationId: Int, clientId: String, controllerId: Int, controllerEpoch: Int, deletePartitions: Boolean, partitions: Set[TopicAndPartition]) extends RequestOrResponse with Product with Serializable
-
-
case class
TopicData(topic: String, partitionData: Map[Int, FetchResponsePartitionData]) extends Product with Serializable
-
-
-
case class
TopicMetadataRequest(versionId: Short, correlationId: Int, clientId: String, topics: Seq[String]) extends RequestOrResponse with Product with Serializable
-
-
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
-