Skip navigation links
A B C D E F G H I K L R S T U V 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.
BeginShutdownControllerHandle - Interface in io.confluent.rest
 
BeginShutdownControllerStatus - Class in io.confluent.rest
 
BeginShutdownControllerStatus(boolean, String) - Constructor for class io.confluent.rest.BeginShutdownControllerStatus
 
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.
ControllerInternalRestServer - Class in io.confluent.rest
 
ControllerInternalRestServer(int, BeginShutdownControllerHandle) - Constructor for class io.confluent.rest.ControllerInternalRestServer
 
ControllerRollHandler - Class in io.confluent.rest
 
ControllerRollHandler(BeginShutdownControllerHandle) - Constructor for class io.confluent.rest.ControllerRollHandler
 

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
 

F

failure - Static variable in class io.confluent.rest.KafkaRestoreRestApiReturnStatus
 
ftpsFile(String, int) - Method in interface io.confluent.rest.KafkaRestorePartitionHandle
The partition's ftps file.

G

generateRollableStatus() - Method in interface io.confluent.rest.BeginShutdownControllerHandle
Generate the status identifying whether we are rollable right now or not, and a reason why not if that is the case.

H

handle(String, Request, HttpServletRequest, HttpServletResponse) - Method in class io.confluent.rest.ControllerRollHandler
 
handle(String, Request, HttpServletRequest, HttpServletResponse) - Method in class io.confluent.rest.RestoreHandler
 
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, KafkaRestorePartitionHandle) - Constructor for class io.confluent.rest.InternalRestServer
 
invalid - Static variable in class io.confluent.rest.KafkaRestoreRestApiReturnStatus
 
io.confluent.rest - package io.confluent.rest
 

K

KafkaRestorePartitionHandle - Interface in io.confluent.rest
This interface is to be used by the InternalRestServer to allow the restore service to communicate with the broker to query relevant kafka state details.
KafkaRestoreRestApiReturnStatus - Class in io.confluent.rest
 
KafkaRestoreRestApiReturnStatus() - Constructor for class io.confluent.rest.KafkaRestoreRestApiReturnStatus
 

L

leaderReplica(String, int) - Method in interface io.confluent.rest.KafkaRestorePartitionHandle
The brokerId corresponding leader of the given replica.

R

reason() - Method in class io.confluent.rest.BeginShutdownControllerStatus
The reason why we are not rollable right now, if that is the case.
ResponseContainer<T> - Class in io.confluent.rest
 
ResponseContainer.DataResponse<T> - Class in io.confluent.rest
 
ResponseContainer.ErrorResponse - Class in io.confluent.rest
 
RestoreHandler - Class in io.confluent.rest
 
RestoreHandler(KafkaRestorePartitionHandle) - Constructor for class io.confluent.rest.RestoreHandler
 
rollable() - Method in class io.confluent.rest.BeginShutdownControllerStatus
Whether this controller is rollable right now or not based on the quorum status (i.e.
RollHandler - Class in io.confluent.rest
 
RollHandler(BeginShutdownBrokerHandle) - Constructor for class io.confluent.rest.RollHandler
 

S

setFenceTierTopicPartition(String, int) - Method in interface io.confluent.rest.KafkaRestorePartitionHandle
Fence tier partition state.
setForceRestoreTierPartition(String, int, long, long, String) - Method in interface io.confluent.rest.KafkaRestorePartitionHandle
Force restore tier partition state.
setUnfreezeLogStartOffset(String, int) - Method in interface io.confluent.rest.KafkaRestorePartitionHandle
Unfreeze log start offset.
start() - Method in class io.confluent.rest.ControllerInternalRestServer
Bind the RestServer to the provided port.
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.ControllerInternalRestServer
 
stop() - Method in class io.confluent.rest.InternalRestServer
 
success - Static variable in class io.confluent.rest.KafkaRestoreRestApiReturnStatus
 

T

tierPartitionStatus(String, int) - Method in interface io.confluent.rest.KafkaRestorePartitionHandle
The tierPartitionStatus corresponding to this broker.
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.

V

validateLogRange(String, int, long, long) - Method in interface io.confluent.rest.KafkaRestorePartitionHandle
Validate if the log view spans across given start and end offset.

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 F G H I K L R S T U V W 
Skip navigation links