Class BrokerTaskResource

java.lang.Object

io.confluent.kafkarest.resources.v3.BrokerTaskResource

@Path("/v3/clusters/{clusterId}/brokers/-/tasks")
public final class BrokerTaskResource
extends Object

Constructor Summary

Constructors

Constructor	Description
BrokerTaskResource(jakarta.inject.Provider<BrokerTaskManager> taskBrokerManager, io.confluent.kafkarest.response.CrnFactory crnFactory, io.confluent.kafkarest.response.UrlFactory urlFactory)

Method Summary

Modifier and Type	Method	Description
void	listBrokerTasks(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId)
void	listBrokerTasksByTaskType(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, BrokerTaskType taskType)

Methods inherited from class java.lang.Object

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

Constructor Details

BrokerTaskResource

@Inject
public BrokerTaskResource(jakarta.inject.Provider<BrokerTaskManager> taskBrokerManager,
 io.confluent.kafkarest.response.CrnFactory crnFactory,
 io.confluent.kafkarest.response.UrlFactory urlFactory)

Method Details

listBrokerTasks

@GET
@Produces("application/json")
@PerformanceMetric("v3.broker-tasks.list")
public void listBrokerTasks(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId)

listBrokerTasksByTaskType

@GET
@Path("/{taskType}")
@Produces("application/json")
@PerformanceMetric("v3.broker-tasks.search-by-type")
public void listBrokerTasksByTaskType(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("taskType")
 BrokerTaskType taskType)