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 Summary
ConstructorsConstructorDescriptionPauseMirrorAction(jakarta.inject.Provider<MirrorManager> mirrorManager, io.confluent.kafkarest.response.UrlFactory urlFactory) -
Method Summary
Modifier and TypeMethodDescriptionvoidpauseMirrors(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String linkName, boolean validateOnly, @Valid AlterMirrorsRequest request)
-
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)
-