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
 
completionStatus() - Method in class io.confluent.rest.TierTopicHeadDataLossDetectionResponse
 
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
 
dataLossReportPath() - Method in class io.confluent.rest.TierTopicHeadDataLossDetectionResponse
 
dataResponse(T) - Static method in class io.confluent.rest.ResponseContainer
Construct a new data response.

E

equals(Object) - Method in class io.confluent.rest.TierRecoveryDataUploadResult
 
equals(Object) - Method in class io.confluent.rest.TierTopicHeadDataLossDetectionRequest
 
equals(Object) - Method in class io.confluent.rest.TierTopicHeadDataLossDetectionResponse
 
errorMessages() - Method in class io.confluent.rest.TierTopicHeadDataLossDetectionResponse
 
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
 
fromStringOrThrow(String) - Static method in enum io.confluent.rest.TierTopicHeadDataLossDetectionResponse.CompletionStatus
 
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.
GetTierRecoveryDataUploadJobResultRequest - Class in io.confluent.rest
 
GetTierRecoveryDataUploadJobResultRequest(UUID) - Constructor for class io.confluent.rest.GetTierRecoveryDataUploadJobResultRequest
 
GetTierRecoveryDataUploadJobResultResponse - Class in io.confluent.rest
 
GetTierRecoveryDataUploadJobResultResponse(TierRecoveryDataUploadResult) - Constructor for class io.confluent.rest.GetTierRecoveryDataUploadJobResultResponse
 

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
 
handle(String, Request, HttpServletRequest, HttpServletResponse) - Method in class io.confluent.rest.TierMetadataRecoveryHandler
 
hashCode() - Method in class io.confluent.rest.TierRecoveryDataUploadResult
 
hashCode() - Method in class io.confluent.rest.TierTopicHeadDataLossDetectionRequest
 
hashCode() - Method in class io.confluent.rest.TierTopicHeadDataLossDetectionResponse
 

I

id - Variable in class io.confluent.rest.ResponseContainer.ErrorResponse
 
identifier() - Method in class io.confluent.rest.TierTopicHeadDataLossDetectionRequest
 
InitiateTierRecoveryDataUploadRequest - Class in io.confluent.rest
 
InitiateTierRecoveryDataUploadRequest(Set<TopicIdPartition>, String, int) - Constructor for class io.confluent.rest.InitiateTierRecoveryDataUploadRequest
 
InitiateTierRecoveryDataUploadResponse - Class in io.confluent.rest
 
InitiateTierRecoveryDataUploadResponse(UUID) - Constructor for class io.confluent.rest.InitiateTierRecoveryDataUploadResponse
 
InternalRestServer - Class in io.confluent.rest
Binds a Rest Server to the provided port, serving the RollHandler API.
InternalRestServer(int, BeginShutdownBrokerHandle, KafkaRestorePartitionHandle, AuditJobHandle, TierMetadataRecoveryHandle) - 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
 
jobId() - Method in class io.confluent.rest.InitiateTierRecoveryDataUploadResponse
 

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

maybeDetectDataLossInTierTopicHead(TierTopicHeadDataLossDetectionRequest, long) - Method in interface io.confluent.rest.TierMetadataRecoveryHandle
 
mayBeGetAuditJobStatusDetail() - Method in interface io.confluent.rest.AuditJobHandle
 
mayBeGetAuditJobStatusSummary() - Method in interface io.confluent.rest.AuditJobHandle
 
maybeGetTierRecoveryDataUploadJobResult(UUID) - Method in interface io.confluent.rest.TierMetadataRecoveryHandle
 
maybeInitiateTierRecoveryDataUpload(Set<TopicIdPartition>, String, int) - Method in interface io.confluent.rest.TierMetadataRecoveryHandle
 
maybeRewindTierTopicConsumer(Optional<Map<Integer, Map<Long, Optional<Integer>>>>, boolean, byte) - Method in interface io.confluent.rest.TierMetadataRecoveryHandle
 
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

OBJECT_MAPPER - Static variable in class io.confluent.rest.TierMetadataRecoveryHandler
 
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
 
result() - Method in class io.confluent.rest.GetTierRecoveryDataUploadJobResultResponse
 
REWIND_PATH - Static variable in class io.confluent.rest.TierMetadataRecoveryHandler
 
RewindTierTopicConsumerRequest - Class in io.confluent.rest
 
RewindTierTopicConsumerRequest(Map<Integer, Map<Long, Optional<Integer>>>, boolean, byte) - Constructor for class io.confluent.rest.RewindTierTopicConsumerRequest
 
RewindTierTopicConsumerResponse - Class in io.confluent.rest
 
RewindTierTopicConsumerResponse(Map<String, Set<Integer>>) - Constructor for class io.confluent.rest.RewindTierTopicConsumerResponse
 
rollable() - Method in interface io.confluent.rest.BeginShutdownBrokerHandle
The value is true when the broker has no URPs and no imbalanced partition on this broker if it's not demoted.
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.
skippedPartitions() - Method in class io.confluent.rest.RewindTierTopicConsumerResponse
 
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
 
status() - Method in class io.confluent.rest.TierRecoveryDataUploadResult
 
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

TIER_TOPIC_HEAD_DATA_LOSS_DETECTION_PATH - Static variable in class io.confluent.rest.TierMetadataRecoveryHandler
 
TierMetadataRecoveryHandle - Interface in io.confluent.rest
 
TierMetadataRecoveryHandler - Class in io.confluent.rest
Handler class for Tier Metadata Recovery API provided by Internal REST server
TierMetadataRecoveryHandler(TierMetadataRecoveryHandle, long) - Constructor for class io.confluent.rest.TierMetadataRecoveryHandler
 
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
 
TierRecoveryDataUploadResult - Class in io.confluent.rest
Stores the result of a completed tier recovery data upload job.
TierRecoveryDataUploadResult(String, TierRecoveryDataUploadResult.TierRecoveryDataUploadJobStatus, Map<TopicIdPartition, String>, boolean, String, boolean, String) - Constructor for class io.confluent.rest.TierRecoveryDataUploadResult
 
TierRecoveryDataUploadResult.TierRecoveryDataUploadJobStatus - Enum in io.confluent.rest
 
TierTopicHeadDataLossDetectionRequest - Class in io.confluent.rest
 
TierTopicHeadDataLossDetectionRequest(String, Set<TopicPartition>) - Constructor for class io.confluent.rest.TierTopicHeadDataLossDetectionRequest
 
TierTopicHeadDataLossDetectionResponse - Class in io.confluent.rest
 
TierTopicHeadDataLossDetectionResponse(String, TierTopicHeadDataLossDetectionResponse.CompletionStatus, List<String>) - Constructor for class io.confluent.rest.TierTopicHeadDataLossDetectionResponse
 
TierTopicHeadDataLossDetectionResponse.CompletionStatus - Enum in io.confluent.rest
 
tierTopicPartitionsAllowList() - Method in class io.confluent.rest.TierTopicHeadDataLossDetectionRequest
 
title - Variable in class io.confluent.rest.ResponseContainer.ErrorResponse
 
toString() - Method in class io.confluent.rest.GetTierRecoveryDataUploadJobResultRequest
 
toString() - Method in class io.confluent.rest.GetTierRecoveryDataUploadJobResultResponse
 
toString() - Method in class io.confluent.rest.InitiateTierRecoveryDataUploadRequest
 
toString() - Method in class io.confluent.rest.InitiateTierRecoveryDataUploadResponse
 
toString() - Method in class io.confluent.rest.ResponseContainer.ErrorResponse
 
toString() - Method in class io.confluent.rest.ResponseContainer
 
toString() - Method in class io.confluent.rest.RewindTierTopicConsumerRequest
 
toString() - Method in class io.confluent.rest.RewindTierTopicConsumerResponse
 
toString() - Method in class io.confluent.rest.TierPartitionStateResponse
 
toString() - Method in class io.confluent.rest.TierRecordMetadataResponse
 
toString() - Method in class io.confluent.rest.TierRecoveryDataUploadResult
 
toString() - Method in class io.confluent.rest.TierTopicHeadDataLossDetectionRequest
 
toString() - Method in class io.confluent.rest.TierTopicHeadDataLossDetectionResponse
 

U

underReplicatedPartitions() - Method in interface io.confluent.rest.BeginShutdownBrokerHandle
The number of under replicated partitions on this broker.
UPLOAD_INITIATE_PATH - Static variable in class io.confluent.rest.TierMetadataRecoveryHandler
 
UPLOAD_RESULT_PATH - Static variable in class io.confluent.rest.TierMetadataRecoveryHandler
 

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.
valueOf(String) - Static method in enum io.confluent.rest.TierRecoveryDataUploadResult.TierRecoveryDataUploadJobStatus
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.confluent.rest.TierTopicHeadDataLossDetectionResponse.CompletionStatus
Returns the enum constant of this type with the specified name.
values() - Static method in enum io.confluent.rest.TierRecoveryDataUploadResult.TierRecoveryDataUploadJobStatus
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.confluent.rest.TierTopicHeadDataLossDetectionResponse.CompletionStatus
Returns an array containing the constants of this enum type, in the order they are declared.

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