Skip navigation links
A B C D E H I R S T U W 

A

attributes - Variable in class io.confluent.rest.ResponseContainer.DataResponse
 

B

beginShutdown(long) - Method in interface io.confluent.rest.BeginShutdownBrokerHandle
Start the shutdown process for this broker on the provided broker epoch.
BeginShutdownBrokerHandle - Interface in io.confluent.rest
This interface is to be used by the InternalRestServer to allow the operator to communicate with the broker and initiate a controlled shutdown dependent on under replicated partitions and the current controller.
brokerEpoch() - Method in interface io.confluent.rest.BeginShutdownBrokerHandle
The brokerEpoch corresponding to this broker.
brokerId() - Method in interface io.confluent.rest.BeginShutdownBrokerHandle
The brokerId corresponding to this broker.

C

controllerId() - Method in interface io.confluent.rest.BeginShutdownBrokerHandle
The brokerId of the current controller.

D

data - Variable in class io.confluent.rest.ResponseContainer
 
dataResponse(T) - Static method in class io.confluent.rest.ResponseContainer
Construct a new data response.

E

errorResponse(List<ResponseContainer.ErrorResponse>) - Static method in class io.confluent.rest.ResponseContainer
Construct a new error response.
ErrorResponse(int, int, String) - Constructor for class io.confluent.rest.ResponseContainer.ErrorResponse
 
errors - Variable in class io.confluent.rest.ResponseContainer
 

H

handle(String, Request, HttpServletRequest, HttpServletResponse) - Method in class io.confluent.rest.RollHandler
 

I

id - Variable in class io.confluent.rest.ResponseContainer.ErrorResponse
 
InternalRestServer - Class in io.confluent.rest
Binds a Rest Server to the provided port, serving the RollHandler API.
InternalRestServer(int, BeginShutdownBrokerHandle) - Constructor for class io.confluent.rest.InternalRestServer
 
io.confluent.rest - package io.confluent.rest
 

R

ResponseContainer<T> - Class in io.confluent.rest
 
ResponseContainer.DataResponse<T> - Class in io.confluent.rest
 
ResponseContainer.ErrorResponse - Class in io.confluent.rest
 
RollHandler - Class in io.confluent.rest
 
RollHandler(BeginShutdownBrokerHandle) - Constructor for class io.confluent.rest.RollHandler
 

S

start() - Method in class io.confluent.rest.InternalRestServer
Bind the RestServer to the provided port.
status - Variable in class io.confluent.rest.ResponseContainer.ErrorResponse
 
stop() - Method in class io.confluent.rest.InternalRestServer
 

T

title - Variable in class io.confluent.rest.ResponseContainer.ErrorResponse
 
toString() - Method in class io.confluent.rest.ResponseContainer.ErrorResponse
 
toString() - Method in class io.confluent.rest.ResponseContainer
 

U

underReplicatedPartitions() - Method in interface io.confluent.rest.BeginShutdownBrokerHandle
The number of under replicated partitions on this broker.

W

write(ObjectMapper, HttpServletResponse) - Method in class io.confluent.rest.ResponseContainer
Write the response to the HttpServletResponse, closing the ServletOutputStream when completed.
A B C D E H I R S T U W 
Skip navigation links