Class ReplicaStatusResource

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

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

    • ReplicaStatusResource

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

    • listReplicaStatus

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