Class MirrorResource

java.lang.Object

io.confluent.kafkarest.resources.v3.MirrorResource

@Path("/v3/clusters/{clusterId}/links/{linkName}/mirrors")
public final class MirrorResource
extends Object

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	createMirror(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String linkName, @Valid CreateMirrorRequest request)
void	getMirror(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String linkName, String mirrorTopicName, Boolean includeStateTransitionErrors)
void	listMirrors(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String linkName, MirrorStatus mirrorStatus)

Methods inherited from class java.lang.Object

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

Constructor Details

MirrorResource

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

Method Details

createMirror

@POST
@Consumes("application/json")
@Produces("application/json")
@PerformanceMetric("v3.mirrors.create")
public void createMirror(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("linkName")
 String linkName,
 @Valid
 @Valid CreateMirrorRequest request)

listMirrors

@GET
@Produces("application/json")
public void listMirrors(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("linkName")
 String linkName,
 @QueryParam("mirror_status")
 MirrorStatus mirrorStatus)

getMirror

@GET
@Path("/{mirrorTopicName}")
@Produces("application/json")
public void getMirror(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("linkName")
 String linkName,
 @PathParam("mirrorTopicName")
 String mirrorTopicName,
 @QueryParam("include_state_transition_errors")
 Boolean includeStateTransitionErrors)