Class ReverseAndPauseMirrorAction

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

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

    • ReverseAndPauseMirrorAction

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

    • reverseAndPauseMirrorAction

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