Class PauseMirrorAction

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

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

    • PauseMirrorAction

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

    • pauseMirrors

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