Class BalancerResource

java.lang.Object

io.confluent.kafkarest.resources.v3.BalancerResource

@Path("/v3/clusters/{clusterId}/balancer")
public final class BalancerResource
extends Object

Constructor Summary

Constructors

Constructor	Description
BalancerResource(jakarta.inject.Provider<BalancerManager> balancerManager, io.confluent.kafkarest.response.CrnFactory crnFactory, io.confluent.kafkarest.response.UrlFactory urlFactory)

Method Summary

Modifier and Type	Method	Description
void	getAnyUnevenLoad(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId)
void	getBalancer(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId)

Methods inherited from class java.lang.Object

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

Constructor Details

BalancerResource

@Inject
public BalancerResource(jakarta.inject.Provider<BalancerManager> balancerManager,
 io.confluent.kafkarest.response.CrnFactory crnFactory,
 io.confluent.kafkarest.response.UrlFactory urlFactory)

Method Details

getBalancer

@GET
@Produces("application/json")
@PerformanceMetric("v3.balancer.get")
public void getBalancer(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId)

getAnyUnevenLoad

@GET
@Path("/any-uneven-load")
@Produces("application/json")
@PerformanceMetric("v3.balancer.any-uneven-load.get")
public void getAnyUnevenLoad(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId)