Class ResumeMirrorAction

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

@Path("/v3/clusters/{clusterId}/links/{linkName}/mirrors:resume") public final class ResumeMirrorAction extends Object
  • Constructor Details

    • ResumeMirrorAction

      @Inject public ResumeMirrorAction(jakarta.inject.Provider<MirrorManager> mirrorManager, io.confluent.kafkarest.response.UrlFactory urlFactory)
  • Method Details

    • resumeMirrors

      @POST @Consumes("application/json") @Produces("application/json") @PerformanceMetric("v3.mirrors.resume") public void resumeMirrors(@Suspended jakarta.ws.rs.container.AsyncResponse asyncResponse, @PathParam("clusterId") String clusterId, @PathParam("linkName") String linkName, @QueryParam("validate_only") boolean validateOnly, @Valid @Valid AlterMirrorsRequest request)