Class ReplicaStatusByPartitionResource

java.lang.Object
io.confluent.kafkarest.resources.v3.ReplicaStatusByPartitionResource

@Path("/v3/clusters/{clusterId}/topics/{topicName}/partitions/{partitionId}/replica-status") public final class ReplicaStatusByPartitionResource extends Object
  • Constructor Details

    • ReplicaStatusByPartitionResource

      @Inject public ReplicaStatusByPartitionResource(jakarta.inject.Provider<ReplicaStatusManager> replicaStatusManager, io.confluent.kafkarest.response.UrlFactory urlFactory)
  • Method Details

    • listReplicaStatus

      @GET @Produces("application/json") @PerformanceMetric("v3.partitions.replica-statuses.list") public void listReplicaStatus(@Suspended jakarta.ws.rs.container.AsyncResponse asyncResponse, @PathParam("clusterId") String clusterId, @PathParam("topicName") String topicName, @PathParam("partitionId") int partitionId)