Skip navigation links
A B C D E F G H I J K L M N O P R S T U V W 

A

attributes - Variable in class io.confluent.rest.ResponseContainer.DataResponse
 
AuditJobHandle - Interface in io.confluent.rest
 
AuditJobHandler - Class in io.confluent.rest
Handler class for Audit job API provided by Internal REST server
AuditJobHandler(AuditJobHandle) - Constructor for class io.confluent.rest.AuditJobHandler
 
AuditJobRestApiResponseStatus - Class in io.confluent.rest
 
AuditJobRestApiResponseStatus() - Constructor for class io.confluent.rest.AuditJobRestApiResponseStatus
 

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

CheckReadyControllerHandle - Interface in io.confluent.rest
 
CheckReadyControllerStatus - Class in io.confluent.rest
 
CheckReadyControllerStatus(boolean, String) - Constructor for class io.confluent.rest.CheckReadyControllerStatus
 
controllerId() - Method in interface io.confluent.rest.BeginShutdownBrokerHandle
The brokerId of the current controller.
ControllerInternalRestServer - Class in io.confluent.rest
 
ControllerInternalRestServer(int, BeginShutdownControllerHandle, CheckReadyControllerHandle) - Constructor for class io.confluent.rest.ControllerInternalRestServer
 
ControllerReadyHandler - Class in io.confluent.rest
 
ControllerReadyHandler(CheckReadyControllerHandle) - Constructor for class io.confluent.rest.ControllerReadyHandler
 
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.AuditJobRestApiResponseStatus
 
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

generateReadinessStatus() - Method in interface io.confluent.rest.CheckReadyControllerHandle
Generate the status identifying whether we are "ready" now or not, and a reason why not if that is the case.
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.AuditJobHandler
 
handle(String, Request, HttpServletRequest, HttpServletResponse) - Method in class io.confluent.rest.ControllerReadyHandler
 
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, AuditJobHandle) - Constructor for class io.confluent.rest.InternalRestServer
 
invalid - Static variable in class io.confluent.rest.AuditJobRestApiResponseStatus
 
invalid - Static variable in class io.confluent.rest.KafkaRestoreRestApiReturnStatus
 
io.confluent.rest - package io.confluent.rest
 

J

JOB_ID - Static variable in class io.confluent.rest.AuditJobHandler
 

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.

M

mayBeGetAuditJobStatusDetail() - Method in interface io.confluent.rest.AuditJobHandle
 
mayBeGetAuditJobStatusSummary() - Method in interface io.confluent.rest.AuditJobHandle
 
mayBeStartAuditJob(Map<String, Set<Integer>>, int, boolean, boolean) - Method in interface io.confluent.rest.AuditJobHandle
 
mayBeStopAuditJob() - Method in interface io.confluent.rest.AuditJobHandle
 

N

NEW_JOB - Static variable in class io.confluent.rest.AuditJobHandler
 

O

offset() - Method in class io.confluent.rest.TierRecordMetadataResponse
 

P

preChecksForRestore(String, int) - Method in interface io.confluent.rest.KafkaRestorePartitionHandle
Validates if restore can be started on the given partition

R

ready() - Method in class io.confluent.rest.CheckReadyControllerStatus
Whether this controller is "ready"" right now or not based on the quorum status (i.e.
reason() - Method in class io.confluent.rest.BeginShutdownControllerStatus
The reason why we are not rollable right now, if that is the case.
reason() - Method in class io.confluent.rest.CheckReadyControllerStatus
The reason why we are not ready 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, byte) - 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 - Static variable in class io.confluent.rest.AuditJobHandler
 
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.AuditJobRestApiResponseStatus
 
success - Static variable in class io.confluent.rest.KafkaRestoreRestApiReturnStatus
 

T

TierPartitionStateResponse - Class in io.confluent.rest
Response to a getTierPartitionState query.
TierPartitionStateResponse(String, int, long, String) - Constructor for class io.confluent.rest.TierPartitionStateResponse
 
tierPartitionStatus(String, int) - Method in interface io.confluent.rest.KafkaRestorePartitionHandle
The tierPartitionStatus corresponding to this broker.
TierRecordMetadataResponse - Class in io.confluent.rest
 
TierRecordMetadataResponse(String, long, long, int) - Constructor for class io.confluent.rest.TierRecordMetadataResponse
 
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
 
toString() - Method in class io.confluent.rest.TierPartitionStateResponse
 
toString() - Method in class io.confluent.rest.TierRecordMetadataResponse
 

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 J K L M N O P R S T U V W 
Skip navigation links