Class ExtensionsBrokersResource

java.lang.Object

io.confluent.kafkarest.resources.v3.ExtensionsBrokersResource

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

Constructor Summary

Constructors

Constructor	Description
ExtensionsBrokersResource(jakarta.inject.Provider<ExtensionsBrokerManager> extensionsBrokerManager, io.confluent.kafkarest.response.CrnFactory crnFactory, io.confluent.kafkarest.response.UrlFactory urlFactory)

Method Summary

Modifier and Type	Method	Description
void	removeBroker(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, Integer brokerId, boolean shouldShutdown)
void	unregisterBroker(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, Integer brokerId)

Methods inherited from class java.lang.Object

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

Constructor Details

ExtensionsBrokersResource

@Inject
public ExtensionsBrokersResource(jakarta.inject.Provider<ExtensionsBrokerManager> extensionsBrokerManager,
 io.confluent.kafkarest.response.CrnFactory crnFactory,
 io.confluent.kafkarest.response.UrlFactory urlFactory)

Method Details

unregisterBroker

@POST
@Path("/{brokerId}:unregister")
@Produces("application/json")
@Consumes("application/json")
@PerformanceMetric("v3.brokers.unregister")
public void unregisterBroker(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("brokerId")
 Integer brokerId)

removeBroker

@DELETE
@Path("/{brokerId}")
@Produces("application/json")
@PerformanceMetric("v3.brokers.delete")
public void removeBroker(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("brokerId")
 Integer brokerId,
 @QueryParam("should_shutdown") @DefaultValue("true")
 boolean shouldShutdown)