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