Class StreamsGroupAssignmentsResource

java.lang.Object

io.confluent.kafkarest.resources.v3.StreamsGroupAssignmentsResource

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

Constructor Summary

Constructors

Constructor	Description
StreamsGroupAssignmentsResource(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	getStreamsGroupAssignments(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String streamsGroupId, String memberId)
void	getStreamsGroupAssignmentTask(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String streamsGroupId, String memberId, StreamsGroupMemberAssignment.AssignmentType assignmentType, String subtopologyId)
void	getStreamsGroupTargetAssignments(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String streamsGroupId, String memberId)
void	getStreamsGroupTargetAssignmentTask(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String streamsGroupId, String memberId, StreamsGroupMemberAssignment.AssignmentType assignmentType, String subtopologyId)
void	listStreamsGroupAssignmentTasks(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String streamsGroupId, String memberId, StreamsGroupMemberAssignment.AssignmentType assignmentType)
void	listStreamsGroupTargetAssignmentTasks(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String streamsGroupId, String memberId, StreamsGroupMemberAssignment.AssignmentType assignmentType)

Methods inherited from class java.lang.Object

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

Constructor Details

StreamsGroupAssignmentsResource

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

Method Details

getStreamsGroupAssignments

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

getStreamsGroupTargetAssignments

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

listStreamsGroupAssignmentTasks

@GET
@Path("/{memberId}/assignments/{assignmentType}")
@Produces("application/json")
@PerformanceMetric("v3.streams-group-members.assignments.assignment-type.get")
public void listStreamsGroupAssignmentTasks(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("groupId")
 String streamsGroupId,
 @PathParam("memberId")
 String memberId,
 @PathParam("assignmentType")
 StreamsGroupMemberAssignment.AssignmentType assignmentType)

listStreamsGroupTargetAssignmentTasks

@GET
@Path("/{memberId}/target-assignments/{assignmentType}")
@Produces("application/json")
@PerformanceMetric("v3.streams-group-members.target-assignments.assignment-type.get")
public void listStreamsGroupTargetAssignmentTasks(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("groupId")
 String streamsGroupId,
 @PathParam("memberId")
 String memberId,
 @PathParam("assignmentType")
 StreamsGroupMemberAssignment.AssignmentType assignmentType)

getStreamsGroupAssignmentTask

@GET
@Path("/{memberId}/assignments/{assignmentType}/subtopologies/{subtopologyId}")
@Produces("application/json")
@PerformanceMetric("v3.streams-group-members.assignments.assignment-type.get")
public void getStreamsGroupAssignmentTask(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("groupId")
 String streamsGroupId,
 @PathParam("memberId")
 String memberId,
 @PathParam("assignmentType")
 StreamsGroupMemberAssignment.AssignmentType assignmentType,
 @PathParam("subtopologyId")
 String subtopologyId)

getStreamsGroupTargetAssignmentTask

@GET
@Path("/{memberId}/target-assignments/{assignmentType}/subtopologies/{subtopologyId}")
@Produces("application/json")
@PerformanceMetric("v3.streams-group-members.target-assignments.assignment-type.get")
public void getStreamsGroupTargetAssignmentTask(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("groupId")
 String streamsGroupId,
 @PathParam("memberId")
 String memberId,
 @PathParam("assignmentType")
 StreamsGroupMemberAssignment.AssignmentType assignmentType,
 @PathParam("subtopologyId")
 String subtopologyId)