Class StreamsGroupSubtopologiesResource

java.lang.Object

io.confluent.kafkarest.resources.v3.StreamsGroupSubtopologiesResource

@Path("/v3/clusters/{clusterId}/streams-groups/{groupId}/subtopologies")
public final class StreamsGroupSubtopologiesResource
extends Object

Constructor Summary

Constructors

Constructor	Description
StreamsGroupSubtopologiesResource(jakarta.inject.Provider<StreamsGroupManager> streamsGroupManager, io.confluent.kafkarest.response.CrnFactory crnFactory, io.confluent.kafkarest.response.UrlFactory urlFactory)

Method Summary

Modifier and Type	Method	Description
void	getStreamsGroupSubtopology(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String streamsGroupId, String subtopologyId)
void	listStreamsGroupSubtopologies(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String streamsGroupId)

Methods inherited from class java.lang.Object

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

Constructor Details

StreamsGroupSubtopologiesResource

@Inject
public StreamsGroupSubtopologiesResource(jakarta.inject.Provider<StreamsGroupManager> streamsGroupManager,
 io.confluent.kafkarest.response.CrnFactory crnFactory,
 io.confluent.kafkarest.response.UrlFactory urlFactory)

Method Details

listStreamsGroupSubtopologies

@GET
@Produces("application/json")
@PerformanceMetric("v3.streams-group-subtopologies.list")
public void listStreamsGroupSubtopologies(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("groupId")
 String streamsGroupId)

getStreamsGroupSubtopology

@GET
@Path("/{subtopologyId}")
@Produces("application/json")
@PerformanceMetric("v3.streams-group-subtopology.get")
public void getStreamsGroupSubtopology(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("groupId")
 String streamsGroupId,
 @PathParam("subtopologyId")
 String subtopologyId)