Class TruncateAndRestoreMirrorAction

java.lang.Object

io.confluent.kafkarest.resources.v3.TruncateAndRestoreMirrorAction

@Path("/v3/clusters/{clusterId}/links/{linkName}/mirrors:truncate-and-restore")
public final class TruncateAndRestoreMirrorAction
extends Object

Constructor Summary

Constructors

Constructor	Description
TruncateAndRestoreMirrorAction(jakarta.inject.Provider<MirrorManager> mirrorManager, io.confluent.kafkarest.response.UrlFactory urlFactory)

Method Summary

Modifier and Type	Method	Description
void	truncateAndRestoreMirrorAction(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String linkName, boolean validateOnly, boolean includePartitionLevelTruncationData, @Valid AlterMirrorsRequest request)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TruncateAndRestoreMirrorAction

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

Method Details

truncateAndRestoreMirrorAction

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