Index

A B C D E F G H I J K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

ACTIVE - Enum constant in enum class io.confluent.kafkarest.entities.MirrorStatus

ACTIVE - Enum constant in enum class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment.AssignmentType

ADD_BROKER - Enum constant in enum class io.confluent.kafkarest.entities.BrokerTaskType

addOffset(PartitionOffsetData) - Method in class io.confluent.kafkarest.entities.v3.PartitionsOffsetsData

ALTER_OFFSETS_INVALID_CONSUMER_GROUP_STATE_ERROR_TMPL - Static variable in class io.confluent.kafkarest.resources.v3.ConsumerGroupOffsetsResource

ALTER_OFFSETS_INVALID_SHARE_GROUP_STATE_ERROR_TMPL - Static variable in class io.confluent.kafkarest.resources.v3.ShareGroupOffsetsResource

AlterBrokerReplicaExclusion - Class in io.confluent.kafkarest.entities

AlterBrokerReplicaExclusion.Builder - Class in io.confluent.kafkarest.entities

A builder for AlterBrokerReplicaExclusion.

AlterBrokerReplicaExclusionData - Class in io.confluent.kafkarest.entities.v3

AlterBrokerReplicaExclusionData.Builder - Class in io.confluent.kafkarest.entities.v3

AlterBrokerReplicaExclusionDataList - Class in io.confluent.kafkarest.entities.v3

AlterBrokerReplicaExclusionDataList.Builder - Class in io.confluent.kafkarest.entities.v3

AlterGroupConfigBatchAction - Class in io.confluent.kafkarest.resources.v3

AlterGroupConfigBatchAction(Provider<GroupConfigManager>) - Constructor for class io.confluent.kafkarest.resources.v3.AlterGroupConfigBatchAction

AlterGroupConfigBatchRequest - Class in io.confluent.kafkarest.entities.v3

alterGroupConfigs(AsyncResponse, String, String, boolean, AlterGroupConfigBatchRequest) - Method in class io.confluent.kafkarest.resources.v3.AlterGroupConfigBatchAction

alterGroupConfigs(String, String, List<AlterConfigCommand>, boolean) - Method in interface io.confluent.kafkarest.controllers.GroupConfigManager

Atomically alters the Kafka Group Configs according to commands.

alterLink(AsyncResponse, String, String, boolean, AlterLinkConfigBatchRequest) - Method in class io.confluent.kafkarest.resources.v3.AlterLinkConfigBatchAction

AlterLinkConfigBatchAction - Class in io.confluent.kafkarest.resources.v3

AlterLinkConfigBatchAction(Provider<LinkConfigManager>) - Constructor for class io.confluent.kafkarest.resources.v3.AlterLinkConfigBatchAction

AlterLinkConfigBatchRequest - Class in io.confluent.kafkarest.entities.v3

alterLinkConfigs(String, String, List<AlterConfigCommand>, boolean) - Method in interface io.confluent.kafkarest.controllers.LinkConfigManager

Atomically alters the Kafka Link Configs according to commands.

AlterMirrorHelper - Class in io.confluent.kafkarest.utils

alterMirrors(UrlFactory, String, String, Supplier<CompletableFuture<List<AlterMirrors>>>) - Static method in class io.confluent.kafkarest.utils.AlterMirrorHelper

AlterMirrors - Class in io.confluent.kafkarest.entities

AlterMirrorsData - Class in io.confluent.kafkarest.entities.v3

AlterMirrorsData.Builder - Class in io.confluent.kafkarest.entities.v3

AlterMirrorsDataList - Class in io.confluent.kafkarest.entities.v3

AlterMirrorsDataList.Builder - Class in io.confluent.kafkarest.entities.v3

AlterMirrorsRequest - Class in io.confluent.kafkarest.entities.v3

AlterMirrorsRequest.Builder - Class in io.confluent.kafkarest.entities.v3

AlterMirrorsResponse - Class in io.confluent.kafkarest.entities.v3

AlterMirrorsResponse() - Constructor for class io.confluent.kafkarest.entities.v3.AlterMirrorsResponse

alterShareGroupOffsets(AsyncResponse, String, String, AlterShareGroupOffsetsRequest) - Method in class io.confluent.kafkarest.resources.v3.ShareGroupOffsetsResource

alterShareGroupOffsets(String, String, AlterShareGroupOffsetsRequest) - Method in interface io.confluent.kafkarest.controllers.ShareGroupManager

Alters offsets for the Kafka ShareGroup with the given shareGroupId.

AlterShareGroupOffsetsRequest - Class in io.confluent.kafkarest.entities.v3

AlterShareGroupOffsetsRequest(String, List<Integer>, ResetType) - Constructor for class io.confluent.kafkarest.entities.v3.AlterShareGroupOffsetsRequest

AlterShareGroupOffsetsResponse - Class in io.confluent.kafkarest.entities.v3

AlterShareGroupOffsetsResponse(String, List<PartitionResult>, String, ResetType) - Constructor for class io.confluent.kafkarest.entities.v3.AlterShareGroupOffsetsResponse

ASSIGNING - Enum constant in enum class io.confluent.kafkarest.entities.StreamsGroup.State

AuthenticationExceptionMapper - Class in io.confluent.kafkarest.exceptions

AuthenticationExceptionMapper() - Constructor for class io.confluent.kafkarest.exceptions.AuthenticationExceptionMapper

B

BAD_REQUEST_ERROR_MSG_ALTER_OFFSETS_TMPL - Static variable in class io.confluent.kafkarest.exceptions.ConsumerGroupOffsetsUtils

Balancer - Class in io.confluent.kafkarest.entities

Balancer.Builder - Class in io.confluent.kafkarest.entities

A builder for Balancer.

BalancerAnyUnevenLoadStatus - Class in io.confluent.kafkarest.entities

BalancerAnyUnevenLoadStatus.Builder - Class in io.confluent.kafkarest.entities

A builder for BalancerAnyUnevenLoadStatus.

BalancerAnyUnevenLoadStatusData - Class in io.confluent.kafkarest.entities.v3

BalancerAnyUnevenLoadStatusData.Builder - Class in io.confluent.kafkarest.entities.v3

BalancerData - Class in io.confluent.kafkarest.entities.v3

BalancerData.Builder - Class in io.confluent.kafkarest.entities.v3

BalancerManager - Interface in io.confluent.kafkarest.controllers

BalancerOfflineException - Exception Class in io.confluent.kafkarest.exceptions

An exception that indicates the Confluent Balancer component is not ready to process requests, either because it is not enabled or because it has not managed to start yet.

BalancerOfflineException(Exception) - Constructor for exception class io.confluent.kafkarest.exceptions.BalancerOfflineException

BalancerResource - Class in io.confluent.kafkarest.resources.v3

BalancerResource(Provider<BalancerManager>, CrnFactory, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.BalancerResource

BROKER_ID_NOT_REGISTERED_ERROR_CODE - Static variable in class io.confluent.kafkarest.exceptions.ErrorCodes

BrokerIdNotRegisteredException - Exception Class in io.confluent.kafkarest.exceptions

An exception that indicates that the broker was not found to be registered in Kafka.

BrokerIdNotRegisteredException(String) - Constructor for exception class io.confluent.kafkarest.exceptions.BrokerIdNotRegisteredException

BrokerNotFoundException - Exception Class in io.confluent.kafkarest.exceptions

An exception that indicates a fetch Kafka broker operation has been attempted for a non existing broker.

BrokerNotFoundException(String, int) - Constructor for exception class io.confluent.kafkarest.exceptions.BrokerNotFoundException

BrokerRemoval - Class in io.confluent.kafkarest.entities

BrokerRemoval.Builder - Class in io.confluent.kafkarest.entities

A builder for BrokerRemoval.

BrokerRemovalData - Class in io.confluent.kafkarest.entities.v3

BrokerRemovalData.Builder - Class in io.confluent.kafkarest.entities.v3

BrokerRemovalDataList - Class in io.confluent.kafkarest.entities.v3

BrokerRemovalDataList.Builder - Class in io.confluent.kafkarest.entities.v3

BrokerReplicaExclusion - Class in io.confluent.kafkarest.entities

BrokerReplicaExclusion.Builder - Class in io.confluent.kafkarest.entities

A builder for BrokerReplicaExclusion.

BrokerReplicaExclusionBatchRequest - Class in io.confluent.kafkarest.entities.v3

BrokerReplicaExclusionBatchRequestData - Class in io.confluent.kafkarest.entities.v3

BrokerReplicaExclusionData - Class in io.confluent.kafkarest.entities.v3

BrokerReplicaExclusionData.Builder - Class in io.confluent.kafkarest.entities.v3

BrokerReplicaExclusionDataList - Class in io.confluent.kafkarest.entities.v3

BrokerReplicaExclusionDataList.Builder - Class in io.confluent.kafkarest.entities.v3

BrokerReplicaExclusionManager - Interface in io.confluent.kafkarest.controllers

BrokerReplicaExclusionRequest - Class in io.confluent.kafkarest.entities.v3

BrokerReplicaExclusionRequest.Builder - Class in io.confluent.kafkarest.entities.v3

BrokerReplicaExclusionResource - Class in io.confluent.kafkarest.resources.v3

BrokerReplicaExclusionResource(Provider<BrokerReplicaExclusionManager>, CrnFactory, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.BrokerReplicaExclusionResource

BrokerSubTaskStatuses - Class in io.confluent.kafkarest.entities

BrokerSubTaskStatuses.Builder - Class in io.confluent.kafkarest.entities

A builder for BrokerSubTaskStatuses.

BrokerSubTaskStatusesData - Class in io.confluent.kafkarest.entities.v3

BrokerSubTaskStatusesData.Builder - Class in io.confluent.kafkarest.entities.v3

BrokerTask - Class in io.confluent.kafkarest.entities

BrokerTask.Builder - Class in io.confluent.kafkarest.entities

A builder for BrokerTask.

BrokerTaskByBrokerResource - Class in io.confluent.kafkarest.resources.v3

BrokerTaskByBrokerResource(Provider<BrokerTaskManager>, CrnFactory, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.BrokerTaskByBrokerResource

BrokerTaskData - Class in io.confluent.kafkarest.entities.v3

BrokerTaskData.Builder - Class in io.confluent.kafkarest.entities.v3

BrokerTaskDataList - Class in io.confluent.kafkarest.entities.v3

BrokerTaskDataList.Builder - Class in io.confluent.kafkarest.entities.v3

BrokerTaskManager - Interface in io.confluent.kafkarest.controllers

BrokerTaskResource - Class in io.confluent.kafkarest.resources.v3

BrokerTaskResource(Provider<BrokerTaskManager>, CrnFactory, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.BrokerTaskResource

BrokerTaskType - Enum Class in io.confluent.kafkarest.entities

Broker task type.

build() - Method in class io.confluent.kafkarest.entities.AlterBrokerReplicaExclusion.Builder

build() - Method in class io.confluent.kafkarest.entities.Balancer.Builder

build() - Method in class io.confluent.kafkarest.entities.BalancerAnyUnevenLoadStatus.Builder

build() - Method in class io.confluent.kafkarest.entities.BrokerRemoval.Builder

build() - Method in class io.confluent.kafkarest.entities.BrokerReplicaExclusion.Builder

build() - Method in class io.confluent.kafkarest.entities.BrokerSubTaskStatuses.Builder

build() - Method in class io.confluent.kafkarest.entities.BrokerTask.Builder

build() - Method in class io.confluent.kafkarest.entities.CellState.Builder

build() - Method in class io.confluent.kafkarest.entities.Link.Builder

build() - Method in class io.confluent.kafkarest.entities.ReplicaStatus.Builder

build() - Method in class io.confluent.kafkarest.entities.ShareConsumer.Builder

build() - Method in class io.confluent.kafkarest.entities.ShareGroup.Builder

build() - Method in class io.confluent.kafkarest.entities.StreamsGroup.Builder

build() - Method in class io.confluent.kafkarest.entities.StreamsGroupMember.Builder

build() - Method in class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment.Builder

build() - Method in class io.confluent.kafkarest.entities.StreamsGroupSubtopology.Builder

build() - Method in class io.confluent.kafkarest.entities.StreamsTask.Builder

build() - Method in class io.confluent.kafkarest.entities.TopicPartitionWithOffset.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.AlterBrokerReplicaExclusionData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsRequest.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.BalancerData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.BrokerRemovalData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionRequest.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.BrokerSubTaskStatusesData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.CellData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.CellStateData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.CreateLinkRequest.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.CreateMirrorRequest.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.GroupConfigData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.LastProducedTimeData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.LinkCategoryData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.LinkConfigData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.LinkData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.LinkTaskData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.LinkTaskErrorData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.ListConsumerGroupOffsetsResultsData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.MirrorData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.MirrorLagData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.PartitionOffsetData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.PartitionTruncationData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokersRequest.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentDataList.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.TopicPartitionData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest.PartitionOffset.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionResponse.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsMultiPartitionResponse.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsSinglePartitionResponse.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeSinglePartitionResponse.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberAssignmentData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupSubtopologyData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.StreamsTaskData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.TopicPartitionOffsetAndMetaData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.UnregisterBrokerData.Builder

build() - Method in class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsRequest.Builder

builder() - Static method in class io.confluent.kafkarest.entities.AlterBrokerReplicaExclusion

builder() - Static method in class io.confluent.kafkarest.entities.Balancer

builder() - Static method in class io.confluent.kafkarest.entities.BalancerAnyUnevenLoadStatus

builder() - Static method in class io.confluent.kafkarest.entities.BrokerRemoval

builder() - Static method in class io.confluent.kafkarest.entities.BrokerReplicaExclusion

builder() - Static method in class io.confluent.kafkarest.entities.BrokerSubTaskStatuses

builder() - Static method in class io.confluent.kafkarest.entities.BrokerTask

builder() - Static method in class io.confluent.kafkarest.entities.CellState

builder() - Static method in class io.confluent.kafkarest.entities.GroupConfig

builder() - Static method in class io.confluent.kafkarest.entities.Link

builder() - Static method in class io.confluent.kafkarest.entities.LinkConfig

builder() - Static method in class io.confluent.kafkarest.entities.ReplicaStatus

builder() - Static method in class io.confluent.kafkarest.entities.ShareConsumer

builder() - Static method in class io.confluent.kafkarest.entities.ShareGroup

builder() - Static method in class io.confluent.kafkarest.entities.StreamsGroup

builder() - Static method in class io.confluent.kafkarest.entities.StreamsGroupMember

builder() - Static method in class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment

builder() - Static method in class io.confluent.kafkarest.entities.StreamsGroupSubtopology

builder() - Static method in class io.confluent.kafkarest.entities.StreamsTask

builder() - Static method in class io.confluent.kafkarest.entities.TopicPartitionWithOffset

builder() - Static method in class io.confluent.kafkarest.entities.v3.AlterBrokerReplicaExclusionData

builder() - Static method in class io.confluent.kafkarest.entities.v3.AlterBrokerReplicaExclusionDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.AlterMirrorsData

builder() - Static method in class io.confluent.kafkarest.entities.v3.AlterMirrorsDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.AlterMirrorsRequest

builder() - Static method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData

builder() - Static method in class io.confluent.kafkarest.entities.v3.BalancerData

builder() - Static method in class io.confluent.kafkarest.entities.v3.BrokerRemovalData

builder() - Static method in class io.confluent.kafkarest.entities.v3.BrokerRemovalDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionData

builder() - Static method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionRequest

builder() - Static method in class io.confluent.kafkarest.entities.v3.BrokerSubTaskStatusesData

builder() - Static method in class io.confluent.kafkarest.entities.v3.BrokerTaskData

builder() - Static method in class io.confluent.kafkarest.entities.v3.BrokerTaskDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.CellData

builder() - Static method in class io.confluent.kafkarest.entities.v3.CellStateData

builder() - Static method in class io.confluent.kafkarest.entities.v3.CreateLinkRequest

builder() - Static method in class io.confluent.kafkarest.entities.v3.CreateMirrorRequest

builder() - Static method in class io.confluent.kafkarest.entities.v3.GroupConfigData

builder() - Static method in class io.confluent.kafkarest.entities.v3.GroupConfigDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.LastProducedTimeData

builder() - Static method in class io.confluent.kafkarest.entities.v3.LastProducedTimeDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.LinkCategoryData

builder() - Static method in class io.confluent.kafkarest.entities.v3.LinkConfigData

builder() - Static method in class io.confluent.kafkarest.entities.v3.LinkConfigDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.LinkData

builder() - Static method in class io.confluent.kafkarest.entities.v3.LinkDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.LinkTaskData

builder() - Static method in class io.confluent.kafkarest.entities.v3.LinkTaskErrorData

builder() - Static method in class io.confluent.kafkarest.entities.v3.ListConsumerGroupOffsetsResultsData

builder() - Static method in class io.confluent.kafkarest.entities.v3.MirrorData

builder() - Static method in class io.confluent.kafkarest.entities.v3.MirrorDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.MirrorLagData

builder() - Static method in class io.confluent.kafkarest.entities.v3.PartitionConsumeData

builder() - Static method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord

builder() - Static method in class io.confluent.kafkarest.entities.v3.PartitionOffsetData

builder() - Static method in class io.confluent.kafkarest.entities.v3.PartitionTruncationData

builder() - Static method in class io.confluent.kafkarest.entities.v3.RemoveBrokersRequest

builder() - Static method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData

builder() - Static method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData

builder() - Static method in class io.confluent.kafkarest.entities.v3.ReplicaStatusDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentData

builder() - Static method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerData

builder() - Static method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.ShareGroupData

builder() - Static method in class io.confluent.kafkarest.entities.v3.ShareGroupData.TopicPartitionData

builder() - Static method in class io.confluent.kafkarest.entities.v3.ShareGroupDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest

builder() - Static method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest.PartitionOffset

builder() - Static method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionResponse

builder() - Static method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsMultiPartitionResponse

builder() - Static method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsSinglePartitionResponse

builder() - Static method in class io.confluent.kafkarest.entities.v3.SimpleConsumeSinglePartitionResponse

builder() - Static method in class io.confluent.kafkarest.entities.v3.StreamsGroupData

builder() - Static method in class io.confluent.kafkarest.entities.v3.StreamsGroupDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberAssignmentData

builder() - Static method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData

builder() - Static method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.StreamsGroupSubtopologyData

builder() - Static method in class io.confluent.kafkarest.entities.v3.StreamsGroupSubtopologyDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.StreamsTaskData

builder() - Static method in class io.confluent.kafkarest.entities.v3.StreamsTaskDataList

builder() - Static method in class io.confluent.kafkarest.entities.v3.TopicPartitionOffsetAndMetaData

builder() - Static method in class io.confluent.kafkarest.entities.v3.UnregisterBrokerData

builder() - Static method in class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsRequest

builder(String, List<Mirror>) - Static method in class io.confluent.kafkarest.entities.v3.MirrorDataList

Builder() - Constructor for class io.confluent.kafkarest.entities.Link.Builder

Builder() - Constructor for class io.confluent.kafkarest.entities.v3.LinkCategoryData.Builder

Builder() - Constructor for class io.confluent.kafkarest.entities.v3.LinkTaskData.Builder

Builder() - Constructor for class io.confluent.kafkarest.entities.v3.LinkTaskErrorData.Builder

Builder() - Constructor for class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.Builder

Builder() - Constructor for class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentData.Builder

Builder() - Constructor for class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest.Builder

Builder() - Constructor for class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest.PartitionOffset.Builder

Builder() - Constructor for class io.confluent.kafkarest.entities.v3.StreamsGroupMemberAssignmentData.Builder

Builder() - Constructor for class io.confluent.kafkarest.entities.v3.StreamsTaskData.Builder

C

CeKafkaRestConfig - Class in io.confluent.kafkarest

CeKafkaRestConfig(Properties) - Constructor for class io.confluent.kafkarest.CeKafkaRestConfig

CeKafkaRestFipsValidator - Class in io.confluent.kafkarest.utils

CeKafkaRestFipsValidator(Map<String, Object>) - Constructor for class io.confluent.kafkarest.utils.CeKafkaRestFipsValidator

CellData - Class in io.confluent.kafkarest.entities.v3

CellData.Builder - Class in io.confluent.kafkarest.entities.v3

CellsManager - Interface in io.confluent.kafkarest.controllers

CellsResource - Class in io.confluent.kafkarest.resources.v3

CellsResource(Provider<CellsManager>, CrnFactory, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.CellsResource

CellState - Class in io.confluent.kafkarest.entities

CellState.Builder - Class in io.confluent.kafkarest.entities

A builder for CellState.

CellStateData - Class in io.confluent.kafkarest.entities.v3

CellStateData.Builder - Class in io.confluent.kafkarest.entities.v3

clean() - Method in class io.confluent.kafkarest.CloudKafkaRestResourceExtension

clean() - Method in class io.confluent.kafkarest.InternalCloudKafkaRestResourceExtension

clean() - Method in class io.confluent.kafkarest.KafkaRestResourceExtension

close() - Method in class io.confluent.kafkarest.auth.OAuthBearerLoginWithIdentityPoolCallbackHandler

close() - Method in class io.confluent.kafkarest.utils.ReferenceCountingHolder

CloudExtensionsAuthFilter - Class in io.confluent.kafkarest.auth

CloudExtensionsAuthFilter(Provider<KafkaRestConfig>, Provider<MultiTenantSaslSecretsStore>) - Constructor for class io.confluent.kafkarest.auth.CloudExtensionsAuthFilter

CloudExtensionsContextFilter - Class in io.confluent.kafkarest.auth

CloudExtensionsContextFilter(KafkaRestConfig) - Constructor for class io.confluent.kafkarest.auth.CloudExtensionsContextFilter

CloudExtensionsControllerModule - Class in io.confluent.kafkarest.controllers

A module to install the cloud specific controllers required by this application.

CloudExtensionsControllerModule() - Constructor for class io.confluent.kafkarest.controllers.CloudExtensionsControllerModule

CloudKafkaModule - Class in io.confluent.kafkarest.backends.kafka

CloudKafkaModule(Provider<KafkaRestConfig>) - Constructor for class io.confluent.kafkarest.backends.kafka.CloudKafkaModule

CloudKafkaRestContext - Class in io.confluent.kafkarest.auth

CloudKafkaRestContext(CloudPrincipal, KafkaRestConfig, RestRequestProxyProtocolInfo) - Constructor for class io.confluent.kafkarest.auth.CloudKafkaRestContext

CloudKafkaRestResourceExtension - Class in io.confluent.kafkarest

CloudKafkaRestResourceExtension() - Constructor for class io.confluent.kafkarest.CloudKafkaRestResourceExtension

CloudPrincipal - Class in io.confluent.kafkarest.auth

CloudRecordSerializerFacade - Class in io.confluent.kafkarest.controllers

CloudSecurityContext - Class in io.confluent.kafkarest.auth

CloudSecurityContext(CloudPrincipal, boolean) - Constructor for class io.confluent.kafkarest.auth.CloudSecurityContext

CloudUIInternalModule - Class in io.confluent.kafkarest.controllers

CloudUIInternalModule() - Constructor for class io.confluent.kafkarest.controllers.CloudUIInternalModule

CloudUIInternalResourcesFeature - Class in io.confluent.kafkarest.resources.v3

Following APIs are called only on the cloud UI, hence "internal".

CloudUIInternalResourcesFeature() - Constructor for class io.confluent.kafkarest.resources.v3.CloudUIInternalResourcesFeature

CloudV3ResourcesModule - Class in io.confluent.kafkarest.resources.v3

CloudV3ResourcesModule() - Constructor for class io.confluent.kafkarest.resources.v3.CloudV3ResourcesModule

CLUSTER_LINK_BOOTSTRAP_TCP_CONNECTION_FAILED_ERROR_CODE - Static variable in class io.confluent.kafkarest.exceptions.ErrorCodes

CLUSTER_LINK_INVALID_BOOTSTRAP_INTERNAL_ERROR_CODE - Static variable in class io.confluent.kafkarest.exceptions.ErrorCodes

CLUSTER_LINK_UNRESOLVABLE_BOOTSTRAP_ERROR_CODE - Static variable in class io.confluent.kafkarest.exceptions.ErrorCodes

ClusterAuthorizationException - Exception Class in io.confluent.kafkarest.exceptions

An exception that indicates that the the authenticated user didn't have CREATE access to the resource.

ClusterAuthorizationException(Throwable) - Constructor for exception class io.confluent.kafkarest.exceptions.ClusterAuthorizationException

ClusterLinkDisabledExceptionMapper - Class in io.confluent.kafkarest.exceptions

ClusterLinkDisabledExceptionMapper() - Constructor for class io.confluent.kafkarest.exceptions.ClusterLinkDisabledExceptionMapper

ClusterLinkExistsException - Exception Class in io.confluent.kafkarest.exceptions

An exception that indicates that a cluster link already exists for the provided link name.

ClusterLinkExistsException(Throwable) - Constructor for exception class io.confluent.kafkarest.exceptions.ClusterLinkExistsException

ClusterLinkInUseExceptionMapper - Class in io.confluent.kafkarest.exceptions

ClusterLinkInUseExceptionMapper() - Constructor for class io.confluent.kafkarest.exceptions.ClusterLinkInUseExceptionMapper

ClusterLinkNotFoundException - Exception Class in io.confluent.kafkarest.exceptions

An exception that indicates that the cluster link doesn't exist.

ClusterLinkNotFoundException(String) - Constructor for exception class io.confluent.kafkarest.exceptions.ClusterLinkNotFoundException

ClusterLinkNotFoundException(Throwable) - Constructor for exception class io.confluent.kafkarest.exceptions.ClusterLinkNotFoundException

COMPLETING_REBALANCE - Enum constant in enum class io.confluent.kafkarest.entities.ShareGroup.State

COMPLETING_REBALANCE - Enum constant in enum class io.confluent.kafkarest.entities.StreamsGroup.State

configure(ResourceInfo, FeatureContext) - Method in class io.confluent.kafkarest.extensions.ForceProduceAuthenticationFeature

configure(FeatureContext) - Method in class io.confluent.kafkarest.resources.ExtensionsResourcesModule

configure(FeatureContext) - Method in class io.confluent.kafkarest.resources.v3.CloudUIInternalResourcesFeature

configure(FeatureContext) - Method in class io.confluent.kafkarest.resources.v3.ExtensionsV3ResourcesFeature

configure(FeatureContext) - Method in class io.confluent.kafkarest.resources.v3.UIInternalResourcesFeature

configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in class io.confluent.kafkarest.auth.OAuthBearerLoginWithIdentityPoolCallbackHandler

consumeFromMultiplePartitions(String, int, Map<Integer, Long>, Boolean, Long, Integer, Integer, Integer, boolean, boolean) - Method in interface io.confluent.kafkarest.controllers.SimpleConsumeManager

consumeFromMultiplePartitions(String, int, Map<Integer, Long>, Boolean, Long, Integer, Integer, Integer, boolean, boolean) - Method in class io.confluent.kafkarest.controllers.SimpleConsumeManagerImpl

consumeFromPartition(AsyncResponse, String, String, Integer, String, String, String, Integer, Integer, Integer) - Method in class io.confluent.kafkarest.resources.v3.SimpleConsumeAction

Consume from single partition

consumeFromPartition(TopicPartition, Boolean, Long, Long, Integer, Integer, Integer) - Method in interface io.confluent.kafkarest.controllers.SimpleConsumeManager

consumeFromPartition(TopicPartition, Boolean, Long, Long, Integer, Integer, Integer) - Method in class io.confluent.kafkarest.controllers.SimpleConsumeManagerImpl

consumeFromPartitions(AsyncResponse, String, String, boolean, SimpleConsumeMultiPartitionRequest) - Method in class io.confluent.kafkarest.resources.v3.SimpleConsumeAction

Consume from multiple partitions, there is no guarantee all partitions are returning records

consumeFromPartitionsGuaranteeProgress(AsyncResponse, String, String, boolean, SimpleConsumeMultiPartitionRequest) - Method in class io.confluent.kafkarest.resources.v3.SimpleConsumeAction

Consume from multiple partitions, guarantee that all partitions are returning records

ConsumerGroupOffsetsManager - Interface in io.confluent.kafkarest.controllers

ConsumerGroupOffsetsManagerImpl - Class in io.confluent.kafkarest.controllers

ConsumerGroupOffsetsManagerImpl(Admin) - Constructor for class io.confluent.kafkarest.controllers.ConsumerGroupOffsetsManagerImpl

ConsumerGroupOffsetsResource - Class in io.confluent.kafkarest.resources.v3

ConsumerGroupOffsetsResource(Provider<ConsumerGroupOffsetsManager>, Provider<ConsumerGroupManager>) - Constructor for class io.confluent.kafkarest.resources.v3.ConsumerGroupOffsetsResource

ConsumerGroupOffsetsUtils - Class in io.confluent.kafkarest.exceptions

ConsumerGroupOffsetsUtils.Error - Class in io.confluent.kafkarest.exceptions

create(int, long, long) - Static method in class io.confluent.kafkarest.entities.v3.PartitionTruncationInfo

create(int, String) - Static method in class io.confluent.kafkarest.exceptions.ConsumerGroupOffsetsUtils.Error

create(HealthCheckStatus) - Static method in class io.confluent.kafkarest.entities.HealthCheckStatusResponse

create(AlterBrokerReplicaExclusionDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListAlterBrokerReplicaExclusionResponse

create(AlterConfigBatchRequestData) - Static method in class io.confluent.kafkarest.entities.v3.AlterGroupConfigBatchRequest

create(AlterConfigBatchRequestData) - Static method in class io.confluent.kafkarest.entities.v3.AlterLinkConfigBatchRequest

create(AlterMirrorsDataList) - Static method in class io.confluent.kafkarest.entities.v3.AlterMirrorsResponse

create(BalancerAnyUnevenLoadStatusData) - Static method in class io.confluent.kafkarest.entities.v3.GetAnyUnevenLoadResponse

create(BalancerData) - Static method in class io.confluent.kafkarest.entities.v3.GetBalancerResponse

create(BrokerRemovalData) - Static method in class io.confluent.kafkarest.entities.v3.GetBrokerRemovalResponse

create(BrokerRemovalDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListBrokerRemovalResponse

create(BrokerReplicaExclusionBatchRequestData) - Static method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionBatchRequest

create(BrokerReplicaExclusionData) - Static method in class io.confluent.kafkarest.entities.v3.GetBrokerReplicaExclusionResponse

create(BrokerReplicaExclusionDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListBrokerReplicaExclusionResponse

create(BrokerTaskData) - Static method in class io.confluent.kafkarest.entities.v3.GetBrokerTaskResponse

create(BrokerTaskDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListBrokerTaskResponse

create(BrokerTaskDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListBrokerTasksByBrokerResponse

create(BrokerTaskDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListBrokerTasksByTaskTypeResponse

create(CellStateData) - Static method in class io.confluent.kafkarest.entities.v3.DescribeCellsResponse

create(GroupConfigData) - Static method in class io.confluent.kafkarest.entities.v3.GetGroupConfigResponse

create(GroupConfigDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListGroupConfigsResponse

create(LastProducedTimeData) - Static method in class io.confluent.kafkarest.entities.v3.GetLastProducedTimeResponse

create(LastProducedTimeDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListLastProducedTimesResponse

create(LinkConfigData) - Static method in class io.confluent.kafkarest.entities.v3.GetLinkConfigResponse

create(LinkConfigDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListLinkConfigsResponse

create(LinkData) - Static method in class io.confluent.kafkarest.entities.v3.GetLinkResponse

create(LinkDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListLinksResponse

create(MirrorData) - Static method in class io.confluent.kafkarest.entities.v3.GetMirrorResponse

create(MirrorDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListMirrorsResponse

create(RemoveBrokerTaskData) - Static method in class io.confluent.kafkarest.entities.v3.GetRemoveBrokerTaskResponse

create(RemoveBrokerTaskDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListRemoveBrokerTaskResponse

create(ReplicaStatusDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListReplicaStatusResponse

create(ShareGroupConsumerAssignmentDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListShareGroupAssignmentsResponse

create(ShareGroupConsumerData) - Static method in class io.confluent.kafkarest.entities.v3.GetShareGroupConsumerResponse

create(ShareGroupConsumerDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListShareGroupConsumersResponse

create(ShareGroupData) - Static method in class io.confluent.kafkarest.entities.v3.GetShareGroupResponse

create(ShareGroupDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListShareGroupsResponse

create(StreamsGroupData) - Static method in class io.confluent.kafkarest.entities.v3.GetStreamsGroupResponse

create(StreamsGroupDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListStreamsGroupsResponse

create(StreamsGroupMemberAssignmentData) - Static method in class io.confluent.kafkarest.entities.v3.GetStreamsGroupMemberAssignmentsResponse

create(StreamsGroupMemberData) - Static method in class io.confluent.kafkarest.entities.v3.GetStreamsGroupMemberResponse

create(StreamsGroupMemberDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListStreamsGroupMembersResponse

create(StreamsGroupSubtopologyData) - Static method in class io.confluent.kafkarest.entities.v3.GetStreamsGroupSubtopologyResponse

create(StreamsGroupSubtopologyDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListStreamsGroupSubtopologiesResponse

create(StreamsTaskData) - Static method in class io.confluent.kafkarest.entities.v3.GetStreamsTaskResponse

create(StreamsTaskDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListStreamsTasksResponse

create(UnregisterBrokerData) - Static method in class io.confluent.kafkarest.entities.v3.UnregisterBrokerResponse

create(Long, UpdateConsumerGroupOffsetsRequest.OffsetType) - Static method in class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsRequest.OffsetData

create(String) - Static method in class io.confluent.kafkarest.entities.v3.UpdateGroupConfigRequest

create(String) - Static method in class io.confluent.kafkarest.entities.v3.UpdateLinkConfigRequest

create(String, int, boolean, BrokerReplicaExclusionStatus, BrokerShutdownStatus, PartitionReassignmentsStatus) - Static method in class io.confluent.kafkarest.entities.RemoveBrokerTask

create(String, int, boolean, BrokerReplicaExclusionStatus, BrokerShutdownStatus, PartitionReassignmentsStatus, short, String) - Static method in class io.confluent.kafkarest.entities.RemoveBrokerTask

create(String, ByteString) - Static method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.Header

create(String, AuthorizationHeader) - Static method in class io.confluent.kafkarest.auth.CloudPrincipal

create(String, AuthorizationHeader, Optional<IdentityPoolIdHeader>) - Static method in class io.confluent.kafkarest.auth.CloudPrincipal

create(String, Integer, UpdateConsumerGroupOffsetsRequest.OffsetData) - Static method in class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsRequest.TopicPartitionOffsetData

create(String, Integer, Integer, String) - Static method in class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsResponse.TopicPartitionResponse

create(String, Integer, String, List<TopicPartitionLag>) - Static method in class io.confluent.kafkarest.entities.AlterMirrors

create(String, Integer, String, List<TopicPartitionLag>, Long, List<PartitionTruncationInfo>) - Static method in class io.confluent.kafkarest.entities.AlterMirrors

create(String, String) - Static method in class io.confluent.kafkarest.entities.v3.CreateLinkRequest.ConfigEntry

create(String, String, long) - Static method in class io.confluent.kafkarest.entities.LastProducedTime

create(String, String, String, int, List<TopicPartitionLag>, MirrorTopicDescription.State, MirrorTopicError, long, List<Long>, List<ClusterLinkTaskError>) - Static method in class io.confluent.kafkarest.entities.Mirror

create(String, String, String, String, boolean, boolean, boolean, ConfigSource, List<ConfigSynonym>) - Static method in class io.confluent.kafkarest.entities.GroupConfig

create(String, String, String, String, boolean, boolean, boolean, ConfigSource, List<ConfigSynonym>) - Static method in class io.confluent.kafkarest.entities.LinkConfig

create(String, String, Uuid, ClusterLinkDescription.LinkMode, ImmutableList<String>, ClusterLinkError, String, ClusterLinkDescription.LinkState, ImmutableList<ClusterLinkTaskDescription>, ClusterLinkDescription.LinkState) - Static method in class io.confluent.kafkarest.entities.Link

create(Principal, KafkaRestConfig, RestRequestProxyProtocolInfo) - Static method in class io.confluent.kafkarest.auth.KafkaRestContextFactory

create(List<BrokerReplicaExclusionRequest>) - Static method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionBatchRequestData

create(List<UpdateConsumerGroupOffsetsResponse.TopicPartitionResponse>) - Static method in class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsResponse

create(TopicPartition, long, long) - Static method in class io.confluent.kafkarest.entities.TopicPartitionLag

CREATE_TIME - Enum constant in enum class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.TimestampType

See TimestampType.CREATE_TIME.

createBrokerReplicaExclusion(AsyncResponse, String, BrokerReplicaExclusionBatchRequest) - Method in class io.confluent.kafkarest.resources.v3.CreateBrokerReplicaExclusionBatchAction

CreateBrokerReplicaExclusionBatchAction - Class in io.confluent.kafkarest.resources.v3

CreateBrokerReplicaExclusionBatchAction(Provider<BrokerReplicaExclusionManager>, CrnFactory, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.CreateBrokerReplicaExclusionBatchAction

createBrokerReplicaExclusions(String, BrokerReplicaExclusionBatchRequest) - Method in interface io.confluent.kafkarest.controllers.BrokerReplicaExclusionManager

Atomically creates BrokerReplicaExclusion for the Kafka Cluster with the given clusterId for the brokers specified with BrokerReplicaExclusionBatchRequest and returns AlterBrokerReplicaExclusion.

createLink(AsyncResponse, String, String, boolean, boolean, CreateLinkRequest) - Method in class io.confluent.kafkarest.resources.v3.LinkResource

createLink(String, Optional<String>, Optional<String>, Optional<String>, Optional<String>, String, Map<String, String>, boolean, boolean) - Method in interface io.confluent.kafkarest.controllers.LinkManager

Creates a new Kafka link.

CreateLinkRequest - Class in io.confluent.kafkarest.entities.v3

CreateLinkRequest.Builder - Class in io.confluent.kafkarest.entities.v3

CreateLinkRequest.ConfigEntry - Class in io.confluent.kafkarest.entities.v3

createMirror(AsyncResponse, String, String, CreateMirrorRequest) - Method in class io.confluent.kafkarest.resources.v3.MirrorResource

createMirror(String, String, String, String, Map<String, Optional<String>>, Optional<Short>) - Method in interface io.confluent.kafkarest.controllers.MirrorManager

Creates a new Kafka mirror with specified replication factor

CreateMirrorRequest - Class in io.confluent.kafkarest.entities.v3

CreateMirrorRequest.Builder - Class in io.confluent.kafkarest.entities.v3

CRITICAL - Enum constant in enum class io.confluent.kafkarest.entities.HealthCheckStatus

Indicates that the service might be in a critical condition or down.

D

DEAD - Enum constant in enum class io.confluent.kafkarest.entities.ShareGroup.State

DEAD - Enum constant in enum class io.confluent.kafkarest.entities.StreamsGroup.State

decrement() - Method in class io.confluent.kafkarest.utils.ReferenceCountingHolder

DefaultTopicConfigManager - Interface in io.confluent.kafkarest.controllers

A service to manage Kafka TopicConfigs.

DefaultTopicConfigsResource - Class in io.confluent.kafkarest.resources.v3

DefaultTopicConfigsResource(Provider<DefaultTopicConfigManager>, CrnFactory, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.DefaultTopicConfigsResource

DELETE - Enum constant in enum class io.confluent.kafkarest.entities.v3.ResetType

Delete offsets for specified partitions.

deleteBrokerReplicaExclusion(AsyncResponse, String, BrokerReplicaExclusionBatchRequest) - Method in class io.confluent.kafkarest.resources.v3.DeleteBrokerReplicaExclusionBatchAction

DeleteBrokerReplicaExclusionBatchAction - Class in io.confluent.kafkarest.resources.v3

DeleteBrokerReplicaExclusionBatchAction(Provider<BrokerReplicaExclusionManager>, CrnFactory, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.DeleteBrokerReplicaExclusionBatchAction

deleteBrokerReplicaExclusions(String, BrokerReplicaExclusionBatchRequest) - Method in interface io.confluent.kafkarest.controllers.BrokerReplicaExclusionManager

Atomically deletes BrokerReplicaExclusion for the Kafka Cluster with the given clusterId for the brokers specified with BrokerReplicaExclusionBatchRequest and returns AlterBrokerReplicaExclusion.

deleteLink(AsyncResponse, String, String, boolean, boolean) - Method in class io.confluent.kafkarest.resources.v3.LinkResource

deleteLink(String, String, boolean, boolean) - Method in interface io.confluent.kafkarest.controllers.LinkManager

Deletes the Kafka link with the given linkName.

deleteShareGroup(AsyncResponse, String, String) - Method in class io.confluent.kafkarest.resources.v3.ShareGroupsResource

deleteShareGroup(String, String) - Method in interface io.confluent.kafkarest.controllers.ShareGroupManager

Deletes the Kafka ShareGroup with the given shareGroupId.

describeCells(AsyncResponse, String) - Method in class io.confluent.kafkarest.resources.v3.CellsResource

describeCells(String) - Method in interface io.confluent.kafkarest.controllers.CellsManager

Returns Cells and corresponding broker state CellState for a Kafka Cluster with given clusterId.

DescribeCellsResponse - Class in io.confluent.kafkarest.entities.v3

E

EARLIEST - Enum constant in enum class io.confluent.kafkarest.entities.v3.ResetType

Reset offsets to earliest.

EARLIEST - Enum constant in enum class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsRequest.OffsetType

ELEMENT_TYPE - Static variable in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData

ELEMENT_TYPE - Static variable in class io.confluent.kafkarest.entities.v3.BalancerData

EMPTY - Enum constant in enum class io.confluent.kafkarest.entities.ShareGroup.State

EMPTY - Enum constant in enum class io.confluent.kafkarest.entities.StreamsGroup.State

equals(Object) - Method in class io.confluent.kafkarest.auth.CloudPrincipal

equals(Object) - Method in class io.confluent.kafkarest.entities.v3.AlterShareGroupOffsetsRequest

equals(Object) - Method in class io.confluent.kafkarest.entities.v3.AlterShareGroupOffsetsResponse

equals(Object) - Method in class io.confluent.kafkarest.entities.v3.PartitionResult

Error() - Constructor for class io.confluent.kafkarest.exceptions.ConsumerGroupOffsetsUtils.Error

ERROR_MESSAGE_MAX_BYTES_CANNOT_BE_NEGATIVE - Static variable in class io.confluent.kafkarest.resources.v3.SimpleConsumeAction

errorCode() - Method in class io.confluent.kafkarest.exceptions.ConsumerGroupOffsetsUtils.Error

ErrorCodes - Class in io.confluent.kafkarest.exceptions

REST application specific error codes.

ErrorCodes() - Constructor for class io.confluent.kafkarest.exceptions.ErrorCodes

errorMessage() - Method in class io.confluent.kafkarest.exceptions.ConsumerGroupOffsetsUtils.Error

ErrorServiceImpl - Class in io.confluent.kafkarest.utils

ErrorServiceImpl() - Constructor for class io.confluent.kafkarest.utils.ErrorServiceImpl

ExceededFields(boolean, boolean) - Constructor for class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.ExceededFields

EXCEPTION_CACHE_CAPACITY_CONFIG - Static variable in class io.confluent.kafkarest.auth.KafkaProducerCacheImpl

EXCEPTION_CACHE_DEFAULT_CAPACITY - Static variable in class io.confluent.kafkarest.auth.KafkaProducerCacheImpl

EXCEPTION_CACHE_DEFAULT_VALIDITY_MILLIS - Static variable in class io.confluent.kafkarest.auth.KafkaProducerCacheImpl

EXCEPTION_CACHE_ENABLE_CONFIG - Static variable in class io.confluent.kafkarest.auth.KafkaProducerCacheImpl

EXCEPTION_CACHE_ENABLE_DEFAULT - Static variable in class io.confluent.kafkarest.auth.KafkaProducerCacheImpl

EXCEPTION_CACHE_VALIDITY_MILLIS_CONFIG - Static variable in class io.confluent.kafkarest.auth.KafkaProducerCacheImpl

ExtensionsBackendsModule - Class in io.confluent.kafkarest.backends

ExtensionsBackendsModule() - Constructor for class io.confluent.kafkarest.backends.ExtensionsBackendsModule

ExtensionsBrokerAction - Class in io.confluent.kafkarest.resources.v3

ExtensionsBrokerAction(Provider<ExtensionsBrokerManager>, CrnFactory, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.ExtensionsBrokerAction

ExtensionsBrokerManager - Interface in io.confluent.kafkarest.controllers

ExtensionsBrokersResource - Class in io.confluent.kafkarest.resources.v3

ExtensionsBrokersResource(Provider<ExtensionsBrokerManager>, CrnFactory, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.ExtensionsBrokersResource

ExtensionsControllersModule - Class in io.confluent.kafkarest.controllers

A module to install the various controllers required by the application.

ExtensionsControllersModule() - Constructor for class io.confluent.kafkarest.controllers.ExtensionsControllersModule

ExtensionsKafkaModule - Class in io.confluent.kafkarest.backends.kafka

ExtensionsKafkaModule() - Constructor for class io.confluent.kafkarest.backends.kafka.ExtensionsKafkaModule

ExtensionsResourcesModule - Class in io.confluent.kafkarest.resources

ExtensionsResourcesModule() - Constructor for class io.confluent.kafkarest.resources.ExtensionsResourcesModule

ExtensionsV3ResourcesFeature - Class in io.confluent.kafkarest.resources.v3

ExtensionsV3ResourcesFeature() - Constructor for class io.confluent.kafkarest.resources.v3.ExtensionsV3ResourcesFeature

extractClusterIdFromUriHost(String) - Static method in class io.confluent.kafkarest.utils.MultiTenantUtils

Return clusterId from host, only applicable for V4 network, throw IllegalArgumentException if host is invalid or clusterId is invalid, otherwise return Optional.empty()

F

FAILED - Enum constant in enum class io.confluent.kafkarest.entities.MirrorStatus

FailoverMirrorAction - Class in io.confluent.kafkarest.resources.v3

FailoverMirrorAction(Provider<MirrorManager>, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.FailoverMirrorAction

failoverMirrors(AsyncResponse, String, String, boolean, AlterMirrorsRequest) - Method in class io.confluent.kafkarest.resources.v3.FailoverMirrorAction

failOverMirrors(String, String, Set<String>, String, boolean) - Method in interface io.confluent.kafkarest.controllers.MirrorManager

Failover the Kafka mirror

filter(ContainerRequestContext) - Method in class io.confluent.kafkarest.auth.CloudExtensionsAuthFilter

filter(ContainerRequestContext) - Method in class io.confluent.kafkarest.auth.CloudExtensionsContextFilter

ForceProduceAuthenticationFeature - Class in io.confluent.kafkarest.extensions

A feature that prevents unauthenticated users from starving Kafka REST of request handling threads via produce calls.

fromAlterBrokerReplicaExclusion(AlterBrokerReplicaExclusion) - Static method in class io.confluent.kafkarest.entities.v3.AlterBrokerReplicaExclusionData

fromAnyUnevenLoad(BalancerAnyUnevenLoadStatus) - Static method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData

fromBalancer(Balancer) - Static method in class io.confluent.kafkarest.entities.v3.BalancerData

fromBrokerRemoval(BrokerRemoval) - Static method in class io.confluent.kafkarest.entities.v3.BrokerRemovalData

fromBrokerReplicaExclusion(BrokerReplicaExclusion) - Static method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionData

fromBrokerSubTaskStatuses(BrokerSubTaskStatuses) - Static method in class io.confluent.kafkarest.entities.v3.BrokerSubTaskStatusesData

fromBrokerTask(BrokerTask) - Static method in class io.confluent.kafkarest.entities.v3.BrokerTaskData

fromBrokerTask(BrokerTask) - Static method in class io.confluent.kafkarest.entities.v3.UnregisterBrokerData

fromCell(DescribeCellsResponseData.Cell) - Static method in class io.confluent.kafkarest.entities.v3.CellData

fromCellList(List<DescribeCellsResponseData.Cell>) - Static method in class io.confluent.kafkarest.entities.v3.CellData

fromCellState(CellState) - Static method in class io.confluent.kafkarest.entities.v3.CellStateData

fromClusterLinkDescription(ClusterLinkDescription) - Static method in class io.confluent.kafkarest.entities.Link

fromClusterLinkTaskDescription(ClusterLinkTaskDescription) - Static method in class io.confluent.kafkarest.entities.v3.LinkTaskData

fromClusterLinkTaskError(ClusterLinkTaskError) - Static method in class io.confluent.kafkarest.entities.v3.LinkTaskErrorData

fromConsumer(ShareConsumer) - Static method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerData

fromGroupConfig(GroupConfig) - Static method in class io.confluent.kafkarest.entities.v3.GroupConfigData

fromGroupState(GroupState) - Static method in enum class io.confluent.kafkarest.entities.ShareGroup.State

fromGroupState(GroupState) - Static method in enum class io.confluent.kafkarest.entities.StreamsGroup.State

fromJson(JsonNode) - Static method in enum class io.confluent.kafkarest.entities.HealthCheckStatus

fromJson(ShareGroupData) - Static method in class io.confluent.kafkarest.entities.v3.GetShareGroupResponse

fromJson(ShareGroupDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListShareGroupsResponse

fromJson(StreamsGroupData) - Static method in class io.confluent.kafkarest.entities.v3.GetStreamsGroupResponse

fromJson(StreamsGroupDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListStreamsGroupsResponse

fromJson(StreamsTaskDataList) - Static method in class io.confluent.kafkarest.entities.v3.ListStreamsTasksResponse

fromJson(String, Resource.Metadata, String, String, StreamsGroup.State, Resource.Relationship, int, int, int, int, Resource.Relationship, int) - Static method in class io.confluent.kafkarest.entities.v3.StreamsGroupData

fromJson(String, ResourceCollection.Metadata, List<RemoveBrokerTaskData>) - Static method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskDataList

fromJson(String, ResourceCollection.Metadata, List<ShareGroupData>) - Static method in class io.confluent.kafkarest.entities.v3.ShareGroupDataList

fromJson(String, ResourceCollection.Metadata, List<StreamsGroupData>) - Static method in class io.confluent.kafkarest.entities.v3.StreamsGroupDataList

fromJson(String, ResourceCollection.Metadata, List<StreamsTaskData>) - Static method in class io.confluent.kafkarest.entities.v3.StreamsTaskDataList

fromJson(String, String, int, long) - Static method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsSinglePartitionResponse

fromJson(String, String, PartitionConsumeData) - Static method in class io.confluent.kafkarest.entities.v3.SimpleConsumeSinglePartitionResponse

fromJson(String, String, List<PartitionConsumeData>) - Static method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionResponse

fromJson(String, String, List<PartitionOffsetData>, Long) - Static method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsMultiPartitionResponse

fromLink(Link) - Static method in class io.confluent.kafkarest.entities.v3.LinkData

fromLinkConfig(LinkConfig) - Static method in class io.confluent.kafkarest.entities.v3.LinkConfigData

fromLinkData(LinkData) - Static method in class io.confluent.kafkarest.entities.v3.LinkData

fromMemberAssignment(String, String, String, StreamsGroupMemberAssignment) - Static method in class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment

fromMemberDescription(String, String, ShareMemberDescription) - Static method in class io.confluent.kafkarest.entities.ShareConsumer

fromMemberDescription(String, String, StreamsGroupMemberDescription) - Static method in class io.confluent.kafkarest.entities.StreamsGroupMember

fromMirror(Mirror) - Static method in class io.confluent.kafkarest.entities.v3.MirrorData

fromMirrors(List<Mirror>, String) - Static method in class io.confluent.kafkarest.entities.v3.MirrorData

fromOffsetAndMetadata(TopicPartition, OffsetAndMetadata) - Static method in class io.confluent.kafkarest.entities.TopicPartitionWithOffset

fromOffsetAndMetadata(TopicPartition, OffsetAndMetadata) - Static method in class io.confluent.kafkarest.entities.v3.TopicPartitionOffsetAndMetaData

fromPartitionInfo(Integer, Long, Long) - Static method in class io.confluent.kafkarest.entities.v3.PartitionTruncationData

fromPartitionLag(Integer, Long, Long) - Static method in class io.confluent.kafkarest.entities.v3.MirrorLagData

fromPartitionLagInfo(List<TopicPartitionLag>) - Static method in class io.confluent.kafkarest.entities.v3.MirrorLagData

fromPartitionTruncationInfo(List<PartitionTruncationInfo>) - Static method in class io.confluent.kafkarest.entities.v3.PartitionTruncationData

fromProducedTime(LastProducedTime) - Static method in class io.confluent.kafkarest.entities.v3.LastProducedTimeData

fromRemoveBrokerTask(RemoveBrokerTask) - Static method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData

fromReplicaStatus(ReplicaStatus) - Static method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData

fromResponseTruncationData(PartitionTruncationInformation) - Static method in class io.confluent.kafkarest.entities.v3.PartitionTruncationInfo

fromShareGroup(ShareGroup) - Static method in class io.confluent.kafkarest.entities.v3.ShareGroupData

fromShareGroupConsumer(ShareConsumer, String) - Static method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerData

fromShareGroupDescription(String, ShareGroupDescription) - Static method in class io.confluent.kafkarest.entities.ShareGroup

fromSharePartitionOffsetInfo(TopicPartition, SharePartitionOffsetInfo) - Static method in class io.confluent.kafkarest.entities.TopicPartitionWithOffset

fromStreamsGroup(StreamsGroup) - Static method in class io.confluent.kafkarest.entities.v3.StreamsGroupData

fromStreamsGroupDescription(String, StreamsGroupDescription) - Static method in class io.confluent.kafkarest.entities.StreamsGroup

fromStreamsGroupSubtopology(StreamsGroupSubtopology, String) - Static method in class io.confluent.kafkarest.entities.v3.StreamsGroupSubtopologyData

fromString(String) - Static method in enum class io.confluent.kafkarest.entities.MirrorStatus

fromString(String) - Static method in enum class io.confluent.kafkarest.entities.v3.ResetType

fromSubtopology(StreamsGroupSubtopology) - Static method in class io.confluent.kafkarest.entities.v3.StreamsGroupSubtopologyData

fromSubtopologyDescription(String, String, StreamsGroupSubtopologyDescription) - Static method in class io.confluent.kafkarest.entities.StreamsGroupSubtopology

fromTaskIds(String, String, String, StreamsGroupMemberAssignment.TaskIds) - Static method in class io.confluent.kafkarest.entities.StreamsTask

G

get() - Method in class io.confluent.kafkarest.utils.ReferenceCountingHolder

getActiveTasks() - Method in class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment

getActiveTasks() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberAssignmentData

getAdmin() - Method in class io.confluent.kafkarest.auth.CloudKafkaRestContext

getAdminProperties() - Method in class io.confluent.kafkarest.auth.CloudKafkaRestContext

getAnyUnevenLoad() - Method in class io.confluent.kafkarest.entities.v3.BalancerData

getAnyUnevenLoad(AsyncResponse, String) - Method in class io.confluent.kafkarest.resources.v3.BalancerResource

getAnyUnevenLoad(String) - Method in interface io.confluent.kafkarest.controllers.BalancerManager

Returns a AnyUnevenLoad for the Kafka Cluster with the given clusterId.

GetAnyUnevenLoadResponse - Class in io.confluent.kafkarest.entities.v3

getAssignedPartitions() - Method in class io.confluent.kafkarest.entities.ShareConsumer

getAssignedTopicPartitions() - Method in class io.confluent.kafkarest.entities.ShareGroup

getAssignedTopicPartitions() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData

getAssignedTopicPartitionsWithOffsets() - Method in class io.confluent.kafkarest.entities.ShareGroup

getAssignment() - Method in class io.confluent.kafkarest.entities.StreamsGroupMember

getAssignments() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerData

getAssignments() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData

getAuthenticationScheme() - Method in class io.confluent.kafkarest.auth.CloudSecurityContext

getAuthorizedOperations() - Method in class io.confluent.kafkarest.entities.ShareGroup

getAuthorizedOperations() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData

getBalancer(AsyncResponse, String) - Method in class io.confluent.kafkarest.resources.v3.BalancerResource

getBalancer(String) - Method in interface io.confluent.kafkarest.controllers.BalancerManager

Returns a Balancer for the Kafka Cluster with the given clusterId.

GetBalancerResponse - Class in io.confluent.kafkarest.entities.v3

getBooleanOrDefault(KafkaRestConfig, String, boolean) - Static method in class io.confluent.kafkarest.CeKafkaRestConfig

getBroker() - Method in class io.confluent.kafkarest.entities.v3.AlterBrokerReplicaExclusionData

getBroker() - Method in class io.confluent.kafkarest.entities.v3.BrokerRemovalData

getBroker() - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionData

getBroker() - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData

getBroker() - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData

getBrokerId() - Method in class io.confluent.kafkarest.entities.AlterBrokerReplicaExclusion

getBrokerId() - Method in class io.confluent.kafkarest.entities.BrokerRemoval

getBrokerId() - Method in class io.confluent.kafkarest.entities.BrokerReplicaExclusion

getBrokerId() - Method in class io.confluent.kafkarest.entities.BrokerTask

getBrokerId() - Method in class io.confluent.kafkarest.entities.RemoveBrokerTask

getBrokerId() - Method in class io.confluent.kafkarest.entities.ReplicaStatus

getBrokerId() - Method in class io.confluent.kafkarest.entities.v3.AlterBrokerReplicaExclusionData

getBrokerId() - Method in class io.confluent.kafkarest.entities.v3.BrokerRemovalData

getBrokerId() - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionData

getBrokerId() - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionRequest

getBrokerId() - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData

getBrokerId() - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData

getBrokerId() - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData

getBrokerId() - Method in class io.confluent.kafkarest.entities.v3.UnregisterBrokerData

getBrokerIds() - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokersRequest

GetBrokerRemovalResponse - Class in io.confluent.kafkarest.entities.v3

getBrokerReplicaExclusion(AsyncResponse, String, int) - Method in class io.confluent.kafkarest.resources.v3.BrokerReplicaExclusionResource

GetBrokerReplicaExclusionResponse - Class in io.confluent.kafkarest.entities.v3

getBrokerReplicaExclusions(String, int) - Method in interface io.confluent.kafkarest.controllers.BrokerReplicaExclusionManager

Returns a BrokerReplicaExclusion for the Kafka Cluster with the given clusterId and Broker with the given brokerId.

getBrokerReplicaExclusionStatus() - Method in class io.confluent.kafkarest.entities.BrokerSubTaskStatuses

getBrokerReplicaExclusionStatus() - Method in class io.confluent.kafkarest.entities.RemoveBrokerTask

getBrokerReplicaExclusionStatus() - Method in class io.confluent.kafkarest.entities.v3.BrokerSubTaskStatusesData

getBrokerReplicaExclusionStatus() - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData

getBrokers() - Method in class io.confluent.kafkarest.entities.v3.CellData

getBrokerShutdownStatus() - Method in class io.confluent.kafkarest.entities.BrokerSubTaskStatuses

getBrokerShutdownStatus() - Method in class io.confluent.kafkarest.entities.RemoveBrokerTask

getBrokerShutdownStatus() - Method in class io.confluent.kafkarest.entities.v3.BrokerSubTaskStatusesData

getBrokerShutdownStatus() - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData

getBrokerSubTaskStatuses() - Method in class io.confluent.kafkarest.entities.BrokerTask

getBrokerSubTaskStatuses() - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData

getBrokerTask() - Method in class io.confluent.kafkarest.entities.v3.BrokerRemovalData

getBrokerTask(AsyncResponse, String, Integer, BrokerTaskType) - Method in class io.confluent.kafkarest.resources.v3.BrokerTaskByBrokerResource

getBrokerTask(String, int, BrokerTaskType) - Method in interface io.confluent.kafkarest.controllers.BrokerTaskManager

Returns a BrokerTask for the Kafka Cluster with the given clusterId, Broker with the given brokerId and BrokerTaskType with the given taskType.

GetBrokerTaskResponse - Class in io.confluent.kafkarest.entities.v3

getBrokerTasks() - Method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData

getBrokerTasks() - Method in class io.confluent.kafkarest.entities.v3.BalancerData

getBrokerTaskStatus() - Method in class io.confluent.kafkarest.entities.BrokerTask

getBrokerTaskStatus() - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData

getBrokerTaskType() - Method in enum class io.confluent.kafkarest.entities.BrokerTaskType

Returns brokerTaskType for the corresponding BrokerTaskType

getCacheKey() - Method in class io.confluent.kafkarest.auth.CloudPrincipal

getCategoryCounts() - Method in class io.confluent.kafkarest.entities.Link

getCategoryCounts() - Method in class io.confluent.kafkarest.entities.v3.LinkData

getCellId() - Method in class io.confluent.kafkarest.entities.v3.CellData

getCells() - Method in class io.confluent.kafkarest.entities.CellState

getCells() - Method in class io.confluent.kafkarest.entities.v3.CellStateData

getCellsEnabled() - Method in class io.confluent.kafkarest.entities.CellState

getCellsEnabled() - Method in class io.confluent.kafkarest.entities.v3.CellStateData

getClientConfigs() - Method in class io.confluent.kafkarest.auth.CloudPrincipal

getClientId() - Method in class io.confluent.kafkarest.entities.ShareConsumer

getClientId() - Method in class io.confluent.kafkarest.entities.StreamsGroupMember

getClientId() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerData

getClientId() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData

getClusterId() - Method in class io.confluent.kafkarest.auth.CloudPrincipal

getClusterId() - Method in class io.confluent.kafkarest.entities.AlterBrokerReplicaExclusion

getClusterId() - Method in class io.confluent.kafkarest.entities.Balancer

getClusterId() - Method in class io.confluent.kafkarest.entities.BalancerAnyUnevenLoadStatus

getClusterId() - Method in class io.confluent.kafkarest.entities.BrokerRemoval

getClusterId() - Method in class io.confluent.kafkarest.entities.BrokerReplicaExclusion

getClusterId() - Method in class io.confluent.kafkarest.entities.BrokerTask

getClusterId() - Method in class io.confluent.kafkarest.entities.CellState

getClusterId() - Method in class io.confluent.kafkarest.entities.LastProducedTime

getClusterId() - Method in class io.confluent.kafkarest.entities.RemoveBrokerTask

getClusterId() - Method in class io.confluent.kafkarest.entities.ReplicaStatus

getClusterId() - Method in class io.confluent.kafkarest.entities.ShareConsumer

getClusterId() - Method in class io.confluent.kafkarest.entities.ShareGroup

getClusterId() - Method in class io.confluent.kafkarest.entities.StreamsGroup

getClusterId() - Method in class io.confluent.kafkarest.entities.StreamsGroupMember

getClusterId() - Method in class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment

getClusterId() - Method in class io.confluent.kafkarest.entities.StreamsGroupSubtopology

getClusterId() - Method in class io.confluent.kafkarest.entities.StreamsTask

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.AlterBrokerReplicaExclusionData

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.BalancerData

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.BrokerRemovalData

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionData

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.CellStateData

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.LastProducedTimeData

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentData

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerData

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionResponse

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsMultiPartitionResponse

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsSinglePartitionResponse

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeSinglePartitionResponse

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberAssignmentData

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupSubtopologyData

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.StreamsTaskData

getClusterId() - Method in class io.confluent.kafkarest.entities.v3.UnregisterBrokerData

getClusterLinkId() - Method in class io.confluent.kafkarest.entities.Link

getClusterLinkId() - Method in class io.confluent.kafkarest.entities.v3.CreateLinkRequest

getClusterLinkId() - Method in class io.confluent.kafkarest.entities.v3.LinkData

getConfig() - Method in class io.confluent.kafkarest.auth.CloudKafkaRestContext

getConfigs() - Method in class io.confluent.kafkarest.entities.v3.CreateLinkRequest

getConfigs() - Method in class io.confluent.kafkarest.entities.v3.CreateMirrorRequest

getConsumer(Properties) - Method in class io.confluent.kafkarest.auth.CloudKafkaRestContext

getConsumer(Properties) - Method in interface io.confluent.kafkarest.controllers.KafkaConsumerProvider

getConsumerCount() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData

getConsumerGroupId() - Method in class io.confluent.kafkarest.entities.ShareConsumer

getConsumerGroupId() - Method in class io.confluent.kafkarest.entities.v3.ListConsumerGroupOffsetsResultsData

getConsumerGroupOffsets(AsyncResponse, String, String) - Method in class io.confluent.kafkarest.resources.v3.ConsumerGroupOffsetsResource

getConsumerGroupOffsets(String) - Method in interface io.confluent.kafkarest.controllers.ConsumerGroupOffsetsManager

getConsumerGroupOffsets(String) - Method in class io.confluent.kafkarest.controllers.ConsumerGroupOffsetsManagerImpl

getConsumerId() - Method in class io.confluent.kafkarest.entities.ShareConsumer

getConsumerId() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentData

getConsumerId() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerData

getConsumerProperties() - Method in class io.confluent.kafkarest.auth.CloudKafkaRestContext

getConsumers() - Method in class io.confluent.kafkarest.entities.ShareGroup

getConsumers() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData

getCoordinator() - Method in class io.confluent.kafkarest.entities.ShareGroup

getCoordinator() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData

getCount() - Method in class io.confluent.kafkarest.entities.v3.LinkCategoryData

getCount() - Method in class io.confluent.kafkarest.utils.ReferenceCountingHolder

getCreatedAt() - Method in class io.confluent.kafkarest.entities.BrokerTask

getCreatedAt() - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData

getData() - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionBatchRequestData

getData() - Method in class io.confluent.kafkarest.entities.v3.GetShareGroupConsumerResponse

getData() - Method in class io.confluent.kafkarest.entities.v3.GetStreamsGroupMemberAssignmentsResponse

getData() - Method in class io.confluent.kafkarest.entities.v3.GetStreamsGroupMemberResponse

getData() - Method in class io.confluent.kafkarest.entities.v3.GetStreamsGroupSubtopologyResponse

getData() - Method in class io.confluent.kafkarest.entities.v3.GetStreamsTaskResponse

getData() - Method in class io.confluent.kafkarest.entities.v3.ListShareGroupAssignmentsResponse

getData() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentDataList

getDestinationClusterId() - Method in class io.confluent.kafkarest.entities.v3.CreateLinkRequest

getDestinationClusterId() - Method in class io.confluent.kafkarest.entities.v3.LinkData

getErrorCode() - Method in class io.confluent.kafkarest.entities.AlterBrokerReplicaExclusion

getErrorCode() - Method in class io.confluent.kafkarest.entities.AlterMirrors

getErrorCode() - Method in class io.confluent.kafkarest.entities.Balancer

getErrorCode() - Method in class io.confluent.kafkarest.entities.BalancerAnyUnevenLoadStatus

getErrorCode() - Method in class io.confluent.kafkarest.entities.BrokerReplicaExclusion

getErrorCode() - Method in class io.confluent.kafkarest.entities.BrokerTask

getErrorCode() - Method in class io.confluent.kafkarest.entities.CellState

getErrorCode() - Method in class io.confluent.kafkarest.entities.RemoveBrokerTask

getErrorCode() - Method in class io.confluent.kafkarest.entities.v3.AlterBrokerReplicaExclusionData

getErrorCode() - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsData

getErrorCode() - Method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData

getErrorCode() - Method in class io.confluent.kafkarest.entities.v3.BalancerData

getErrorCode() - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionData

getErrorCode() - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData

getErrorCode() - Method in class io.confluent.kafkarest.entities.v3.CellStateData

getErrorCode() - Method in class io.confluent.kafkarest.entities.v3.LinkTaskErrorData

getErrorCode() - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData

getErrorCode() - Method in class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsResponse.TopicPartitionResponse

getErrorCount() - Static method in class io.confluent.kafkarest.utils.ErrorServiceImpl

getErrorMessage() - Method in class io.confluent.kafkarest.entities.AlterBrokerReplicaExclusion

getErrorMessage() - Method in class io.confluent.kafkarest.entities.AlterMirrors

getErrorMessage() - Method in class io.confluent.kafkarest.entities.Balancer

getErrorMessage() - Method in class io.confluent.kafkarest.entities.BalancerAnyUnevenLoadStatus

getErrorMessage() - Method in class io.confluent.kafkarest.entities.BrokerReplicaExclusion

getErrorMessage() - Method in class io.confluent.kafkarest.entities.BrokerTask

getErrorMessage() - Method in class io.confluent.kafkarest.entities.CellState

getErrorMessage() - Method in class io.confluent.kafkarest.entities.RemoveBrokerTask

getErrorMessage() - Method in class io.confluent.kafkarest.entities.v3.AlterBrokerReplicaExclusionData

getErrorMessage() - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsData

getErrorMessage() - Method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData

getErrorMessage() - Method in class io.confluent.kafkarest.entities.v3.BalancerData

getErrorMessage() - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionData

getErrorMessage() - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData

getErrorMessage() - Method in class io.confluent.kafkarest.entities.v3.CellStateData

getErrorMessage() - Method in class io.confluent.kafkarest.entities.v3.LinkTaskErrorData

getErrorMessage() - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData

getErrorMessage() - Method in class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsResponse.TopicPartitionResponse

getErrors() - Method in class io.confluent.kafkarest.entities.v3.LinkTaskData

getExceededFields() - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord

getExclusion() - Method in class io.confluent.kafkarest.entities.AlterBrokerReplicaExclusion

getExclusion() - Method in class io.confluent.kafkarest.entities.v3.AlterBrokerReplicaExclusionData

getFetchMaxBytes() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest

getFromBeginning() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest

getGroupConfig(AsyncResponse, String, String, String) - Method in class io.confluent.kafkarest.resources.v3.GroupConfigResource

getGroupConfig(String, String, String) - Method in interface io.confluent.kafkarest.controllers.GroupConfigManager

Returns the Kafka GroupConfig with the given name.

GetGroupConfigResponse - Class in io.confluent.kafkarest.entities.v3

getGroupEpoch() - Method in class io.confluent.kafkarest.entities.ShareGroup

getGroupEpoch() - Method in class io.confluent.kafkarest.entities.StreamsGroup

getGroupEpoch() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData

getGroupEpoch() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData

getGroupId() - Method in class io.confluent.kafkarest.entities.GroupConfig

getGroupId() - Method in class io.confluent.kafkarest.entities.v3.GroupConfigData

getHeaders() - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord

getHealthCheckStatus() - Method in interface io.confluent.kafkarest.controllers.HealthCheckManager

Returns a health-check status for this Kafka REST instance.

getHost() - Method in class io.confluent.kafkarest.entities.ShareConsumer

getInstanceId() - Method in class io.confluent.kafkarest.entities.ShareConsumer

getInstanceId() - Method in class io.confluent.kafkarest.entities.StreamsGroupMember

getInstanceId() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData

getIntOrDefault(KafkaRestConfig, String, int) - Static method in class io.confluent.kafkarest.CeKafkaRestConfig

getIsClassic() - Method in class io.confluent.kafkarest.entities.StreamsGroupMember

getIsClassic() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData

getKafkaConsumerManager() - Method in class io.confluent.kafkarest.auth.CloudKafkaRestContext

getKey() - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord

getKey() - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.Header

getLag() - Method in class io.confluent.kafkarest.entities.TopicPartitionLag

getLag() - Method in class io.confluent.kafkarest.entities.v3.MirrorLagData

getLastCaughtUpTimeMs() - Method in class io.confluent.kafkarest.entities.ReplicaStatus

getLastCaughtUpTimeMs() - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData

getLastFetchTimeMs() - Method in class io.confluent.kafkarest.entities.ReplicaStatus

getLastFetchTimeMs() - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData

getLastProducedTime(AsyncResponse, String, String) - Method in class io.confluent.kafkarest.resources.v3.GetLastProducedTimeAction

getLastProducedTime(String, String) - Method in interface io.confluent.kafkarest.controllers.LastProducedTimeManager

Returns the lastProducedTime for the last message produced to a given clusterId and topicName.

GetLastProducedTimeAction - Class in io.confluent.kafkarest.resources.v3

GetLastProducedTimeAction(Provider<LastProducedTimeManager>, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.GetLastProducedTimeAction

getLastProducedTimeMs() - Method in class io.confluent.kafkarest.entities.LastProducedTime

getLastProducedTimeMs() - Method in class io.confluent.kafkarest.entities.v3.LastProducedTimeData

GetLastProducedTimeResponse - Class in io.confluent.kafkarest.entities.v3

getLastSourceFetchHighWatermark() - Method in class io.confluent.kafkarest.entities.TopicPartitionLag

getLastSourceFetchHighWatermark() - Method in class io.confluent.kafkarest.entities.v3.MirrorLagData

getLink(AsyncResponse, String, String, Boolean) - Method in class io.confluent.kafkarest.resources.v3.LinkResource

getLink(String, String, Boolean) - Method in interface io.confluent.kafkarest.controllers.LinkManager

Returns the specific Kafka links belonging to the Cluster with the given clusterId and the given linkName.

getLinkConfig(AsyncResponse, String, String, String) - Method in class io.confluent.kafkarest.resources.v3.LinkConfigResource

getLinkConfig(String, String, String) - Method in interface io.confluent.kafkarest.controllers.LinkConfigManager

Returns the Kafka LinkConfig with the given name.

GetLinkConfigResponse - Class in io.confluent.kafkarest.entities.v3

getLinkError() - Method in class io.confluent.kafkarest.entities.Link

getLinkError() - Method in class io.confluent.kafkarest.entities.v3.LinkData

getLinkErrorMessage() - Method in class io.confluent.kafkarest.entities.Link

getLinkErrorMessage() - Method in class io.confluent.kafkarest.entities.v3.LinkData

getLinkId() - Method in class io.confluent.kafkarest.entities.Link

getLinkId() - Method in class io.confluent.kafkarest.entities.v3.LinkData

getLinkMode() - Method in class io.confluent.kafkarest.entities.Link

getLinkName() - Method in class io.confluent.kafkarest.entities.Link

getLinkName() - Method in class io.confluent.kafkarest.entities.LinkConfig

getLinkName() - Method in class io.confluent.kafkarest.entities.Mirror

getLinkName() - Method in class io.confluent.kafkarest.entities.ReplicaStatus

getLinkName() - Method in class io.confluent.kafkarest.entities.v3.LinkConfigData

getLinkName() - Method in class io.confluent.kafkarest.entities.v3.LinkData

getLinkName() - Method in class io.confluent.kafkarest.entities.v3.MirrorData

getLinkName() - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData

GetLinkResponse - Class in io.confluent.kafkarest.entities.v3

getLinkState() - Method in class io.confluent.kafkarest.entities.Link

getLinkState() - Method in class io.confluent.kafkarest.entities.v3.LinkData

getLogEndOffset() - Method in class io.confluent.kafkarest.entities.ReplicaStatus

getLogEndOffset() - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData

getLogStartOffset() - Method in class io.confluent.kafkarest.entities.ReplicaStatus

getLogStartOffset() - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData

getLongOrDefault(KafkaRestConfig, String, long) - Static method in class io.confluent.kafkarest.CeKafkaRestConfig

getMaxPollRecords() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest

getMemberCount() - Method in class io.confluent.kafkarest.entities.StreamsGroup

getMemberCount() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData

getMemberEpoch() - Method in class io.confluent.kafkarest.entities.StreamsGroupMember

getMemberEpoch() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData

getMemberId() - Method in class io.confluent.kafkarest.entities.StreamsGroupMember

getMemberId() - Method in class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment

getMemberId() - Method in class io.confluent.kafkarest.entities.StreamsTask

getMemberId() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberAssignmentData

getMemberId() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData

getMemberId() - Method in class io.confluent.kafkarest.entities.v3.StreamsTaskData

getMembers() - Method in class io.confluent.kafkarest.entities.StreamsGroup

getMembers() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData

getMessageMaxBytes() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest

getMessagesTruncated() - Method in class io.confluent.kafkarest.entities.AlterMirrors

getMessagesTruncated() - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsData

getMessagesTruncated() - Method in class io.confluent.kafkarest.entities.v3.PartitionTruncationData

getMessagesTruncated() - Method in class io.confluent.kafkarest.entities.v3.PartitionTruncationInfo

getMetadata() - Method in class io.confluent.kafkarest.entities.v3.TopicPartitionOffsetAndMetaData

getMirror(AsyncResponse, String, String, String, Boolean) - Method in class io.confluent.kafkarest.resources.v3.MirrorResource

getMirror(String, String, String, Boolean) - Method in interface io.confluent.kafkarest.controllers.MirrorManager

Returns a list of Kafka mirrors belonging to the Link with the given clusterId, linkName, and mirrorTopicName.

getMirrorLags() - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsData

getMirrorLags() - Method in class io.confluent.kafkarest.entities.v3.MirrorData

GetMirrorResponse - Class in io.confluent.kafkarest.entities.v3

getMirrorStateTransitionErrors() - Method in class io.confluent.kafkarest.entities.Mirror

getMirrorStateTransitionErrors() - Method in class io.confluent.kafkarest.entities.v3.MirrorData

getMirrorStatus() - Method in class io.confluent.kafkarest.entities.Mirror

getMirrorStatus() - Method in class io.confluent.kafkarest.entities.v3.MirrorData

getMirrorTopicError() - Method in class io.confluent.kafkarest.entities.Mirror

getMirrorTopicError() - Method in class io.confluent.kafkarest.entities.v3.MirrorData

getMirrorTopicName() - Method in class io.confluent.kafkarest.entities.AlterMirrors

getMirrorTopicName() - Method in class io.confluent.kafkarest.entities.Mirror

getMirrorTopicName() - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsData

getMirrorTopicName() - Method in class io.confluent.kafkarest.entities.v3.CreateMirrorRequest

getMirrorTopicName() - Method in class io.confluent.kafkarest.entities.v3.MirrorData

getMirrorTopicNamePattern() - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsRequest

getMirrorTopicNames() - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsRequest

getName() - Method in class io.confluent.kafkarest.entities.v3.CreateLinkRequest.ConfigEntry

getNextOffset() - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeData

getNextOffset() - Method in class io.confluent.kafkarest.entities.v3.PartitionOffsetData

getNextOffset() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsSinglePartitionResponse

getNumPartitions() - Method in class io.confluent.kafkarest.entities.Mirror

getNumPartitions() - Method in class io.confluent.kafkarest.entities.v3.MirrorData

getOffset() - Method in class io.confluent.kafkarest.entities.TopicPartitionWithOffset

getOffset() - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord

getOffset() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.TopicPartitionData

getOffset() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest.PartitionOffset

getOffset() - Method in class io.confluent.kafkarest.entities.v3.TopicPartitionOffsetAndMetaData

getOffset() - Method in class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsRequest.OffsetData

getOffsetData() - Method in class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsRequest.TopicPartitionOffsetData

getOffsetForPartition(TopicPartition, Boolean, Long) - Method in interface io.confluent.kafkarest.controllers.SimpleConsumeManager

getOffsetForPartition(TopicPartition, Boolean, Long) - Method in class io.confluent.kafkarest.controllers.SimpleConsumeManagerImpl

getOffsets() - Method in class io.confluent.kafkarest.entities.v3.ListConsumerGroupOffsetsResultsData

getOffsets() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest

getOffsetsForPartition(AsyncResponse, String, String, Integer, String, String) - Method in class io.confluent.kafkarest.resources.v3.SimpleConsumeAction

getOffsetsForPartitions(AsyncResponse, String, String, String, String) - Method in class io.confluent.kafkarest.resources.v3.SimpleConsumeAction

getOffsetsForPartitions(String, int, Boolean, Long) - Method in interface io.confluent.kafkarest.controllers.SimpleConsumeManager

getOffsetsForPartitions(String, int, Boolean, Long) - Method in class io.confluent.kafkarest.controllers.SimpleConsumeManagerImpl

getOffsetsList() - Method in class io.confluent.kafkarest.entities.v3.PartitionsOffsetsData

getOffsetTruncatedTo() - Method in class io.confluent.kafkarest.entities.v3.PartitionTruncationData

getOffsetTruncatedTo() - Method in class io.confluent.kafkarest.entities.v3.PartitionTruncationInfo

getOffsetType() - Method in class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsRequest.OffsetData

getOpenForTenantAssignment() - Method in class io.confluent.kafkarest.entities.v3.CellData

getOperationType() - Method in class io.confluent.kafkarest.entities.v3.AlterShareGroupOffsetsResponse

getOverallSerializedMessageSize(List<ConsumerRecord<byte[], byte[]>>) - Static method in class io.confluent.kafkarest.controllers.SimpleConsumeManagerImpl

getPartition() - Method in class io.confluent.kafkarest.entities.v3.MirrorLagData

getPartition() - Method in class io.confluent.kafkarest.entities.v3.PartitionResult

getPartition() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentData

getPartition() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.TopicPartitionData

getPartitionCount() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData

getPartitionData() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeSinglePartitionResponse

getPartitionDataList() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionResponse

getPartitionId() - Method in class io.confluent.kafkarest.entities.ReplicaStatus

getPartitionId() - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeData

getPartitionId() - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord

getPartitionId() - Method in class io.confluent.kafkarest.entities.v3.PartitionOffsetData

getPartitionId() - Method in class io.confluent.kafkarest.entities.v3.PartitionTruncationData

getPartitionId() - Method in class io.confluent.kafkarest.entities.v3.PartitionTruncationInfo

getPartitionId() - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData

getPartitionId() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentData

getPartitionId() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.TopicPartitionData

getPartitionId() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest.PartitionOffset

getPartitionId() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsSinglePartitionResponse

getPartitionId() - Method in class io.confluent.kafkarest.entities.v3.TopicPartitionOffsetAndMetaData

getPartitionId() - Method in class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsRequest.TopicPartitionOffsetData

getPartitionId() - Method in class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsResponse.TopicPartitionResponse

getPartitionIds() - Method in class io.confluent.kafkarest.entities.StreamsTask

getPartitionIds() - Method in class io.confluent.kafkarest.entities.v3.StreamsTaskData

getPartitionLagList() - Method in class io.confluent.kafkarest.entities.AlterMirrors

getPartitionLagList() - Method in class io.confluent.kafkarest.entities.Mirror

getPartitionLevelTruncationData() - Method in class io.confluent.kafkarest.entities.AlterMirrors

getPartitionLevelTruncationData() - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsData

getPartitionOffsetList() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsMultiPartitionResponse

getPartitionReassignmentStatus() - Method in class io.confluent.kafkarest.entities.BrokerSubTaskStatuses

getPartitionReassignmentStatus() - Method in class io.confluent.kafkarest.entities.RemoveBrokerTask

getPartitionReassignmentStatus() - Method in class io.confluent.kafkarest.entities.v3.BrokerSubTaskStatusesData

getPartitionReassignmentStatus() - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData

getPartitions() - Method in class io.confluent.kafkarest.entities.v3.AlterShareGroupOffsetsRequest

getPartitions() - Method in class io.confluent.kafkarest.entities.v3.AlterShareGroupOffsetsResponse

getPreviousStatus() - Method in class io.confluent.kafkarest.entities.BalancerAnyUnevenLoadStatus

getPreviousStatus() - Method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData

getPreviousStatusUpdatedAt() - Method in class io.confluent.kafkarest.entities.BalancerAnyUnevenLoadStatus

getPreviousStatusUpdatedAt() - Method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData

getProcessId() - Method in class io.confluent.kafkarest.entities.StreamsGroupMember

getProcessId() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData

getProducer() - Method in class io.confluent.kafkarest.auth.CloudKafkaRestContext

getProducerCacheKey() - Method in class io.confluent.kafkarest.auth.CloudKafkaRestContext

getProducerCallable(Map<String, Object>) - Static method in class io.confluent.kafkarest.auth.KafkaProducerCacheUtils

getProducerCallable(Map<String, Object>, Cache<Map.Entry<String, String>, ApiException>, String) - Static method in class io.confluent.kafkarest.auth.KafkaProducerCacheUtils

getProducerConfigs() - Method in class io.confluent.kafkarest.auth.CloudKafkaRestContext

getReason() - Method in class io.confluent.kafkarest.entities.AlterBrokerReplicaExclusion

getReason() - Method in class io.confluent.kafkarest.entities.BrokerReplicaExclusion

getReason() - Method in class io.confluent.kafkarest.entities.v3.AlterBrokerReplicaExclusionData

getReason() - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionData

getReason() - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionRequest

getRecords() - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeData

getRemoteClusterId() - Method in class io.confluent.kafkarest.entities.Link

getRemoteClusterId() - Method in class io.confluent.kafkarest.entities.v3.CreateLinkRequest

getRemoteClusterId() - Method in class io.confluent.kafkarest.entities.v3.LinkData

getRemoteLinkState() - Method in class io.confluent.kafkarest.entities.Link

getRemoveBrokerTask(AsyncResponse, String, Integer) - Method in class io.confluent.kafkarest.resources.v3.RemoveBrokerTaskResource

getRemoveBrokerTask(String, int) - Method in interface io.confluent.kafkarest.controllers.RemoveBrokerTaskManager

Returns the Task for the Kafka Cluster with the given clusterId and Broker with the given brokerId.

GetRemoveBrokerTaskResponse - Class in io.confluent.kafkarest.entities.v3

getReplicationFactor() - Method in class io.confluent.kafkarest.entities.v3.CreateMirrorRequest

getRequestStatus(ListAlterBrokerReplicaExclusionResponse) - Static method in class io.confluent.kafkarest.entities.v3.ListAlterBrokerReplicaExclusionResponse

getResetType() - Method in class io.confluent.kafkarest.entities.v3.AlterShareGroupOffsetsRequest

getScheme() - Method in class io.confluent.kafkarest.auth.CloudPrincipal

getServiceHealth(AsyncResponse) - Method in class io.confluent.kafkarest.resources.HealthCheckAction

getShareGroup(AsyncResponse, String, String) - Method in class io.confluent.kafkarest.resources.v3.ShareGroupsResource

getShareGroup(String, String) - Method in interface io.confluent.kafkarest.controllers.ShareGroupManager

Returns the Kafka ShareGroup with the given shareGroupId.

getShareGroupConsumer(AsyncResponse, String, String, String) - Method in class io.confluent.kafkarest.resources.v3.ShareGroupConsumersResource

GetShareGroupConsumerResponse - Class in io.confluent.kafkarest.entities.v3

GetShareGroupConsumerResponse(ShareGroupConsumerData) - Constructor for class io.confluent.kafkarest.entities.v3.GetShareGroupConsumerResponse

getShareGroupId() - Method in class io.confluent.kafkarest.entities.ShareGroup

getShareGroupId() - Method in class io.confluent.kafkarest.entities.v3.AlterShareGroupOffsetsResponse

getShareGroupId() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentData

getShareGroupId() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerData

getShareGroupId() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData

GetShareGroupResponse - Class in io.confluent.kafkarest.entities.v3

getShutdownScheduled() - Method in class io.confluent.kafkarest.entities.BrokerTask

getShutdownScheduled() - Method in class io.confluent.kafkarest.entities.RemoveBrokerTask

getShutdownScheduled() - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData

getShutdownScheduled() - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData

getSourceClusterId() - Method in class io.confluent.kafkarest.entities.v3.CreateLinkRequest

getSourceClusterId() - Method in class io.confluent.kafkarest.entities.v3.LinkData

getSourceTopicName() - Method in class io.confluent.kafkarest.entities.Mirror

getSourceTopicName() - Method in class io.confluent.kafkarest.entities.v3.CreateMirrorRequest

getSourceTopicName() - Method in class io.confluent.kafkarest.entities.v3.MirrorData

getSourceTopics() - Method in class io.confluent.kafkarest.entities.StreamsGroupSubtopology

getSourceTopics() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupSubtopologyData

getStandbyTasks() - Method in class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment

getStandbyTasks() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberAssignmentData

getStartOffset() - Method in class io.confluent.kafkarest.entities.v3.PartitionResult

getState() - Method in enum class io.confluent.kafkarest.entities.MirrorStatus

getState() - Method in class io.confluent.kafkarest.entities.ShareGroup

getState() - Method in class io.confluent.kafkarest.entities.StreamsGroup

getState() - Method in class io.confluent.kafkarest.entities.v3.CellData

getState() - Method in class io.confluent.kafkarest.entities.v3.LinkTaskData

getState() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData

getState() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData

getStateCategory() - Method in class io.confluent.kafkarest.entities.v3.LinkCategoryData

getStateTimeMs() - Method in class io.confluent.kafkarest.entities.v3.MirrorData

getStatus() - Method in class io.confluent.kafkarest.entities.Balancer

getStatus() - Method in class io.confluent.kafkarest.entities.BalancerAnyUnevenLoadStatus

getStatus() - Method in enum class io.confluent.kafkarest.entities.HealthCheckStatus

getStatus() - Method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData

getStatus() - Method in class io.confluent.kafkarest.entities.v3.BalancerData

getStatus() - Method in class io.confluent.kafkarest.entities.v3.PartitionResult

getStatusCode() - Method in enum class io.confluent.kafkarest.entities.HealthCheckStatus

getStatusTimeMs() - Method in class io.confluent.kafkarest.entities.Mirror

getStatusUpdatedAt() - Method in class io.confluent.kafkarest.entities.BalancerAnyUnevenLoadStatus

getStatusUpdatedAt() - Method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData

getStoppedLogEndOffsets() - Method in class io.confluent.kafkarest.entities.Mirror

getStreamsGroup(AsyncResponse, String, String) - Method in class io.confluent.kafkarest.resources.v3.StreamsGroupsResource

getStreamsGroup(String, String) - Method in interface io.confluent.kafkarest.controllers.StreamsGroupManager

Returns the Kafka StreamsGroup with the given streamsGroupId.

getStreamsGroupAssignments(AsyncResponse, String, String, String) - Method in class io.confluent.kafkarest.resources.v3.StreamsGroupAssignmentsResource

getStreamsGroupAssignmentTask(AsyncResponse, String, String, String, StreamsGroupMemberAssignment.AssignmentType, String) - Method in class io.confluent.kafkarest.resources.v3.StreamsGroupAssignmentsResource

getStreamsGroupId() - Method in class io.confluent.kafkarest.entities.StreamsGroup

getStreamsGroupId() - Method in class io.confluent.kafkarest.entities.StreamsGroupMember

getStreamsGroupId() - Method in class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment

getStreamsGroupId() - Method in class io.confluent.kafkarest.entities.StreamsGroupSubtopology

getStreamsGroupId() - Method in class io.confluent.kafkarest.entities.StreamsTask

getStreamsGroupId() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData

getStreamsGroupId() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberAssignmentData

getStreamsGroupId() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData

getStreamsGroupId() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupSubtopologyData

getStreamsGroupId() - Method in class io.confluent.kafkarest.entities.v3.StreamsTaskData

getStreamsGroupMember(AsyncResponse, String, String, String) - Method in class io.confluent.kafkarest.resources.v3.StreamsGroupMembersResource

GetStreamsGroupMemberAssignmentsResponse - Class in io.confluent.kafkarest.entities.v3

GetStreamsGroupMemberAssignmentsResponse(StreamsGroupMemberAssignmentData) - Constructor for class io.confluent.kafkarest.entities.v3.GetStreamsGroupMemberAssignmentsResponse

GetStreamsGroupMemberResponse - Class in io.confluent.kafkarest.entities.v3

GetStreamsGroupMemberResponse(StreamsGroupMemberData) - Constructor for class io.confluent.kafkarest.entities.v3.GetStreamsGroupMemberResponse

GetStreamsGroupResponse - Class in io.confluent.kafkarest.entities.v3

getStreamsGroupSubtopology(AsyncResponse, String, String, String) - Method in class io.confluent.kafkarest.resources.v3.StreamsGroupSubtopologiesResource

GetStreamsGroupSubtopologyResponse - Class in io.confluent.kafkarest.entities.v3

GetStreamsGroupSubtopologyResponse(StreamsGroupSubtopologyData) - Constructor for class io.confluent.kafkarest.entities.v3.GetStreamsGroupSubtopologyResponse

getStreamsGroupTargetAssignments(AsyncResponse, String, String, String) - Method in class io.confluent.kafkarest.resources.v3.StreamsGroupAssignmentsResource

getStreamsGroupTargetAssignmentTask(AsyncResponse, String, String, String, StreamsGroupMemberAssignment.AssignmentType, String) - Method in class io.confluent.kafkarest.resources.v3.StreamsGroupAssignmentsResource

GetStreamsTaskResponse - Class in io.confluent.kafkarest.entities.v3

GetStreamsTaskResponse(StreamsTaskData) - Constructor for class io.confluent.kafkarest.entities.v3.GetStreamsTaskResponse

getSubtopologies() - Method in class io.confluent.kafkarest.entities.StreamsGroup

getSubtopologies() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData

getSubtopologyCount() - Method in class io.confluent.kafkarest.entities.StreamsGroup

getSubtopologyCount() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData

getSubtopologyId() - Method in class io.confluent.kafkarest.entities.StreamsGroupSubtopology

getSubtopologyId() - Method in class io.confluent.kafkarest.entities.StreamsTask

getSubtopologyId() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupSubtopologyData

getSubtopologyId() - Method in class io.confluent.kafkarest.entities.v3.StreamsTaskData

getTargetAssignment() - Method in class io.confluent.kafkarest.entities.StreamsGroupMember

getTargetAssignmentEpoch() - Method in class io.confluent.kafkarest.entities.ShareGroup

getTargetAssignmentEpoch() - Method in class io.confluent.kafkarest.entities.StreamsGroup

getTargetAssignmentEpoch() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData

getTargetAssignmentEpoch() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData

getTargetAssignments() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData

getTaskName() - Method in class io.confluent.kafkarest.entities.v3.LinkTaskData

getTasks() - Method in class io.confluent.kafkarest.entities.Link

getTasks() - Method in class io.confluent.kafkarest.entities.v3.LinkData

getTaskType() - Method in class io.confluent.kafkarest.entities.BrokerTask

getTaskType() - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData

getTimestamp() - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord

getTimestamp() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest

getTimestampType() - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord

getTopic() - Method in class io.confluent.kafkarest.entities.v3.AlterShareGroupOffsetsRequest

getTopic() - Method in class io.confluent.kafkarest.entities.v3.AlterShareGroupOffsetsResponse

getTopicName() - Method in class io.confluent.kafkarest.entities.LastProducedTime

getTopicName() - Method in class io.confluent.kafkarest.entities.ReplicaStatus

getTopicName() - Method in class io.confluent.kafkarest.entities.v3.LastProducedTimeData

getTopicName() - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData

getTopicName() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentData

getTopicName() - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.TopicPartitionData

getTopicName() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionResponse

getTopicName() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsMultiPartitionResponse

getTopicName() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsSinglePartitionResponse

getTopicName() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeSinglePartitionResponse

getTopicName() - Method in class io.confluent.kafkarest.entities.v3.TopicPartitionOffsetAndMetaData

getTopicName() - Method in class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsRequest.TopicPartitionOffsetData

getTopicName() - Method in class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsResponse.TopicPartitionResponse

getTopicPartition() - Method in class io.confluent.kafkarest.entities.TopicPartitionLag

getTopicPartition() - Method in class io.confluent.kafkarest.entities.TopicPartitionWithOffset

getTopicPartitionOffsetRequests() - Method in class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsRequest

getTopics() - Method in class io.confluent.kafkarest.entities.Link

getTopics() - Method in class io.confluent.kafkarest.entities.v3.LinkData

getTopologyEpoch() - Method in class io.confluent.kafkarest.entities.StreamsGroup

getTopologyEpoch() - Method in class io.confluent.kafkarest.entities.StreamsGroupMember

getTopologyEpoch() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData

getTopologyEpoch() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData

getTotalRecords() - Method in class io.confluent.kafkarest.entities.v3.PartitionsOffsetsData

getTotalRecords() - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsMultiPartitionResponse

getUpdatedAt() - Method in class io.confluent.kafkarest.entities.BrokerTask

getUpdatedAt() - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData

getUpdateResponses() - Method in class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsResponse

getUserPrincipal() - Method in class io.confluent.kafkarest.auth.CloudSecurityContext

getValue() - Method in class io.confluent.kafkarest.entities.HealthCheckStatusResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.AlterGroupConfigBatchRequest

getValue() - Method in class io.confluent.kafkarest.entities.v3.AlterLinkConfigBatchRequest

getValue() - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionBatchRequest

getValue() - Method in class io.confluent.kafkarest.entities.v3.CreateLinkRequest.ConfigEntry

getValue() - Method in class io.confluent.kafkarest.entities.v3.DescribeCellsResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.GetAnyUnevenLoadResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.GetBalancerResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.GetBrokerRemovalResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.GetBrokerReplicaExclusionResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.GetBrokerTaskResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.GetGroupConfigResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.GetLastProducedTimeResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.GetLinkConfigResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.GetLinkResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.GetMirrorResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.GetRemoveBrokerTaskResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.GetShareGroupResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.GetStreamsGroupResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListAlterBrokerReplicaExclusionResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListBrokerRemovalResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListBrokerReplicaExclusionResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListBrokerTaskResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListBrokerTasksByBrokerResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListBrokerTasksByTaskTypeResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListGroupConfigsResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListLastProducedTimesResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListLinkConfigsResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListLinksResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListMirrorsResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListRemoveBrokerTaskResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListReplicaStatusResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListShareGroupConsumersResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListShareGroupsResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListStreamsGroupMembersResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListStreamsGroupsResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListStreamsGroupSubtopologiesResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.ListStreamsTasksResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord

getValue() - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.Header

getValue() - Method in enum class io.confluent.kafkarest.entities.v3.ResetType

getValue() - Method in class io.confluent.kafkarest.entities.v3.UnregisterBrokerResponse

getValue() - Method in class io.confluent.kafkarest.entities.v3.UpdateGroupConfigRequest

getValue() - Method in class io.confluent.kafkarest.entities.v3.UpdateLinkConfigRequest

getWarmupTasks() - Method in class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment

getWarmupTasks() - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberAssignmentData

GROUP_UNAUTHORIZED_ERROR_MSG_ALTER_OFFSETS_TMPL - Static variable in class io.confluent.kafkarest.exceptions.ConsumerGroupOffsetsUtils

GroupConfig - Class in io.confluent.kafkarest.entities

GroupConfig.Builder - Class in io.confluent.kafkarest.entities

A builder for GroupConfig.

GroupConfigData - Class in io.confluent.kafkarest.entities.v3

GroupConfigData.Builder - Class in io.confluent.kafkarest.entities.v3

GroupConfigDataList - Class in io.confluent.kafkarest.entities.v3

GroupConfigDataList.Builder - Class in io.confluent.kafkarest.entities.v3

GroupConfigManager - Interface in io.confluent.kafkarest.controllers

GroupConfigResource - Class in io.confluent.kafkarest.resources.v3

GroupConfigResource(Provider<GroupConfigManager>, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.GroupConfigResource

H

handle(Callback[]) - Method in class io.confluent.kafkarest.auth.OAuthBearerLoginWithIdentityPoolCallbackHandler

hashCode() - Method in class io.confluent.kafkarest.auth.CloudPrincipal

hashCode() - Method in class io.confluent.kafkarest.entities.v3.AlterShareGroupOffsetsRequest

hashCode() - Method in class io.confluent.kafkarest.entities.v3.AlterShareGroupOffsetsResponse

hashCode() - Method in class io.confluent.kafkarest.entities.v3.PartitionResult

Header() - Constructor for class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.Header

HealthCheckAction - Class in io.confluent.kafkarest.resources

HealthCheckAction(Provider<HealthCheckManager>) - Constructor for class io.confluent.kafkarest.resources.HealthCheckAction

HealthCheckManager - Interface in io.confluent.kafkarest.controllers

Provides health-check functionality for this Kafka REST instance.

HealthCheckStatus - Enum Class in io.confluent.kafkarest.entities

Represents the result of a service health check.

HealthCheckStatusResponse - Class in io.confluent.kafkarest.entities

HealthCheckStatusResponse() - Constructor for class io.confluent.kafkarest.entities.HealthCheckStatusResponse

I

IllegalBrokerRemovalException - Exception Class in io.confluent.kafkarest.exceptions

An exception that indicates a Kafka broker removal operation has been attempted for a invalid broker.

IllegalBrokerRemovalException(Throwable) - Constructor for exception class io.confluent.kafkarest.exceptions.IllegalBrokerRemovalException

increment() - Method in class io.confluent.kafkarest.utils.ReferenceCountingHolder

INTERNAL_SERVER_ERROR_MSG_ALTER_OFFSETS_TMPL - Static variable in class io.confluent.kafkarest.exceptions.ConsumerGroupOffsetsUtils

INTERNAL_SERVER_ERROR_MSG_LIST_OFFSETS_TMPL - Static variable in class io.confluent.kafkarest.exceptions.ConsumerGroupOffsetsUtils

InternalCloudKafkaRestResourceExtension - Class in io.confluent.kafkarest

InternalCloudKafkaRestResourceExtension() - Constructor for class io.confluent.kafkarest.InternalCloudKafkaRestResourceExtension

InvalidClusterLinkException - Exception Class in io.confluent.kafkarest.exceptions

An exception that indicates that the cluster link name is illegal

InvalidClusterLinkException(InvalidClusterLinkException) - Constructor for exception class io.confluent.kafkarest.exceptions.InvalidClusterLinkException

InvalidConfigNameException - Exception Class in io.confluent.kafkarest.exceptions

An exception that indicates that the config name is illegal

InvalidConfigNameException(String) - Constructor for exception class io.confluent.kafkarest.exceptions.InvalidConfigNameException

InvalidConfigNameException(Throwable) - Constructor for exception class io.confluent.kafkarest.exceptions.InvalidConfigNameException

InvalidRequestBodyException - Exception Class in io.confluent.kafkarest.exceptions

An exception indicating that the request body is invalid.

InvalidRequestBodyException(String) - Constructor for exception class io.confluent.kafkarest.exceptions.InvalidRequestBodyException

InvalidRequestBodyException(Throwable) - Constructor for exception class io.confluent.kafkarest.exceptions.InvalidRequestBodyException

InvalidTopicException - Exception Class in io.confluent.kafkarest.exceptions

InvalidTopicException(String) - Constructor for exception class io.confluent.kafkarest.exceptions.InvalidTopicException

InvalidTopicException(Throwable) - Constructor for exception class io.confluent.kafkarest.exceptions.InvalidTopicException

io.confluent.kafkarest - package io.confluent.kafkarest

io.confluent.kafkarest.auth - package io.confluent.kafkarest.auth

io.confluent.kafkarest.backends - package io.confluent.kafkarest.backends

io.confluent.kafkarest.backends.kafka - package io.confluent.kafkarest.backends.kafka

io.confluent.kafkarest.controllers - package io.confluent.kafkarest.controllers

io.confluent.kafkarest.entities - package io.confluent.kafkarest.entities

io.confluent.kafkarest.entities.v3 - package io.confluent.kafkarest.entities.v3

io.confluent.kafkarest.exceptions - package io.confluent.kafkarest.exceptions

io.confluent.kafkarest.extensions - package io.confluent.kafkarest.extensions

io.confluent.kafkarest.metrics - package io.confluent.kafkarest.metrics

io.confluent.kafkarest.resources - package io.confluent.kafkarest.resources

io.confluent.kafkarest.resources.v3 - package io.confluent.kafkarest.resources.v3

io.confluent.kafkarest.utils - package io.confluent.kafkarest.utils

isCaughtUp() - Method in class io.confluent.kafkarest.entities.ReplicaStatus

isCaughtUp() - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData

isInIsr() - Method in class io.confluent.kafkarest.entities.ReplicaStatus

isInIsr() - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData

isIsrEligible() - Method in class io.confluent.kafkarest.entities.ReplicaStatus

isIsrEligible() - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData

isKey() - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.ExceededFields

isLeader() - Method in class io.confluent.kafkarest.entities.ReplicaStatus

isLeader() - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData

isObserver() - Method in class io.confluent.kafkarest.entities.ReplicaStatus

isObserver() - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData

isSecure() - Method in class io.confluent.kafkarest.auth.CloudSecurityContext

isUserInRole(String) - Method in class io.confluent.kafkarest.auth.CloudSecurityContext

isValue() - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.ExceededFields

J

jsonFromBytes(byte[], Headers, boolean, boolean) - Static method in class io.confluent.kafkarest.utils.SimpleConsumeKeyValueDeserializer

Deserializes a byte array into a JSON-compatible object, determining whether to return the raw bytes (as a Base64-encoded string in a JSON object) or a UTF-8 string, based on the following order of precedence: Header check: If the Kafka headers contain a schema ID for the key or value, the raw bytes are returned as a Base64-encoded string in a JSON object. Magic byte: If the first byte matches the expected magic byte, the raw bytes are returned as a Base64-encoded string in a JSON object. Query parameter: If returnRawBase64Records is true, the raw bytes are returned as a Base64-encoded string in a JSON object. UTF-8 string: Otherwise, the bytes are interpreted as a UTF-8 string and returned as such.

K

KAFKA_HEADERS_KEY_FOR_KEY_SCHEMA_ID - Static variable in class io.confluent.kafkarest.utils.SimpleConsumeKeyValueDeserializer

KAFKA_HEADERS_KEY_FOR_VALUE_SCHEMA_ID - Static variable in class io.confluent.kafkarest.utils.SimpleConsumeKeyValueDeserializer

KAFKA_PRODUCER_CACHE_ENABLE_CONFIG - Static variable in class io.confluent.kafkarest.backends.kafka.CloudKafkaModule

KAFKA_REST_CONTEXT_PROPERTY_NAME - Static variable in class io.confluent.kafkarest.backends.kafka.CloudKafkaModule

KafkaConsumerProvider - Interface in io.confluent.kafkarest.controllers

KafkaProducerCache - Interface in io.confluent.kafkarest.backends.kafka

KafkaProducerCacheImpl - Class in io.confluent.kafkarest.auth

KafkaProducerCacheImpl(Provider<KafkaRestConfig>) - Constructor for class io.confluent.kafkarest.auth.KafkaProducerCacheImpl

KafkaProducerCacheUtils - Class in io.confluent.kafkarest.auth

KafkaRestContextFactory - Class in io.confluent.kafkarest.auth

KafkaRestResourceExtension - Class in io.confluent.kafkarest

KafkaRestResourceExtension() - Constructor for class io.confluent.kafkarest.KafkaRestResourceExtension

L

LastProducedTime - Class in io.confluent.kafkarest.entities

LastProducedTimeData - Class in io.confluent.kafkarest.entities.v3

LastProducedTimeData.Builder - Class in io.confluent.kafkarest.entities.v3

LastProducedTimeDataList - Class in io.confluent.kafkarest.entities.v3

LastProducedTimeDataList.Builder - Class in io.confluent.kafkarest.entities.v3

LastProducedTimeManager - Interface in io.confluent.kafkarest.controllers

A service to manage LastProducedTime.

LATEST - Enum constant in enum class io.confluent.kafkarest.entities.v3.ResetType

Reset offsets to latest.

LATEST - Enum constant in enum class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsRequest.OffsetType

Link - Class in io.confluent.kafkarest.entities

LINK_FAILED - Enum constant in enum class io.confluent.kafkarest.entities.MirrorStatus

LINK_PAUSED - Enum constant in enum class io.confluent.kafkarest.entities.MirrorStatus

Link.Builder - Class in io.confluent.kafkarest.entities

LinkCategoryData - Class in io.confluent.kafkarest.entities.v3

LinkCategoryData.Builder - Class in io.confluent.kafkarest.entities.v3

LinkConfig - Class in io.confluent.kafkarest.entities

LinkConfig.Builder - Class in io.confluent.kafkarest.entities

A builder for LinkConfig.

LinkConfigData - Class in io.confluent.kafkarest.entities.v3

LinkConfigData.Builder - Class in io.confluent.kafkarest.entities.v3

LinkConfigDataList - Class in io.confluent.kafkarest.entities.v3

LinkConfigDataList.Builder - Class in io.confluent.kafkarest.entities.v3

LinkConfigManager - Interface in io.confluent.kafkarest.controllers

LinkConfigResource - Class in io.confluent.kafkarest.resources.v3

LinkConfigResource(Provider<LinkConfigManager>, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.LinkConfigResource

LinkData - Class in io.confluent.kafkarest.entities.v3

LinkData.Builder - Class in io.confluent.kafkarest.entities.v3

LinkDataList - Class in io.confluent.kafkarest.entities.v3

LinkDataList.Builder - Class in io.confluent.kafkarest.entities.v3

LinkManager - Interface in io.confluent.kafkarest.controllers

A service to manage Kafka links.

LinkResource - Class in io.confluent.kafkarest.resources.v3

LinkResource(Provider<LinkManager>, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.LinkResource

LinkTaskData - Class in io.confluent.kafkarest.entities.v3

LinkTaskData() - Constructor for class io.confluent.kafkarest.entities.v3.LinkTaskData

LinkTaskData.Builder - Class in io.confluent.kafkarest.entities.v3

LinkTaskErrorData - Class in io.confluent.kafkarest.entities.v3

LinkTaskErrorData() - Constructor for class io.confluent.kafkarest.entities.v3.LinkTaskErrorData

LinkTaskErrorData.Builder - Class in io.confluent.kafkarest.entities.v3

listAllLastProducedTimes(AsyncResponse, String) - Method in class io.confluent.kafkarest.resources.v3.ListAllLastProducedTimesAction

ListAllLastProducedTimesAction - Class in io.confluent.kafkarest.resources.v3

ListAllLastProducedTimesAction(Provider<LastProducedTimeManager>, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.ListAllLastProducedTimesAction

listAllMirrors(AsyncResponse, String, String) - Method in class io.confluent.kafkarest.resources.v3.ListAllMirrorsAction

ListAllMirrorsAction - Class in io.confluent.kafkarest.resources.v3

ListAllMirrorsAction(Provider<MirrorManager>, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.ListAllMirrorsAction

listAllReplicaStatuses(AsyncResponse, String) - Method in class io.confluent.kafkarest.resources.v3.ListAllReplicaStatusesAction

ListAllReplicaStatusesAction - Class in io.confluent.kafkarest.resources.v3

ListAllReplicaStatusesAction(Provider<ReplicaStatusManager>, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.ListAllReplicaStatusesAction

ListAlterBrokerReplicaExclusionResponse - Class in io.confluent.kafkarest.entities.v3

ListBrokerRemovalResponse - Class in io.confluent.kafkarest.entities.v3

ListBrokerReplicaExclusionResponse - Class in io.confluent.kafkarest.entities.v3

listBrokerReplicaExclusions(AsyncResponse, String) - Method in class io.confluent.kafkarest.resources.v3.BrokerReplicaExclusionResource

listBrokerReplicaExclusions(String) - Method in interface io.confluent.kafkarest.controllers.BrokerReplicaExclusionManager

Returns a list of all Kafka BrokerReplicaExclusion for a Kafka Cluster with given clusterId.

ListBrokerTaskResponse - Class in io.confluent.kafkarest.entities.v3

listBrokerTasks(AsyncResponse, String) - Method in class io.confluent.kafkarest.resources.v3.BrokerTaskResource

listBrokerTasks(String) - Method in interface io.confluent.kafkarest.controllers.BrokerTaskManager

Returns a list of all Kafka BrokerTask for a Kafka Cluster with given clusterId.

listBrokerTasksByBroker(AsyncResponse, String, Integer) - Method in class io.confluent.kafkarest.resources.v3.BrokerTaskByBrokerResource

listBrokerTasksByBroker(String, int) - Method in interface io.confluent.kafkarest.controllers.BrokerTaskManager

Returns a list of BrokerTask for the Kafka Cluster with the given clusterId and Broker with the given brokerId

ListBrokerTasksByBrokerResponse - Class in io.confluent.kafkarest.entities.v3

listBrokerTasksByTaskType(AsyncResponse, String, BrokerTaskType) - Method in class io.confluent.kafkarest.resources.v3.BrokerTaskResource

listBrokerTasksByTaskType(String, BrokerTaskType) - Method in interface io.confluent.kafkarest.controllers.BrokerTaskManager

Returns a list of Kafka BrokerTask of BrokerTaskType with given taskType for a Kafka Cluster with given clusterId.

ListBrokerTasksByTaskTypeResponse - Class in io.confluent.kafkarest.entities.v3

listClusterReplicaStatus(String) - Method in interface io.confluent.kafkarest.controllers.ReplicaStatusManager

Returns the list of Statuses for all of Kafka Topic with the given clusterId

ListConsumerGroupOffsetsResultsData - Class in io.confluent.kafkarest.entities.v3

ListConsumerGroupOffsetsResultsData() - Constructor for class io.confluent.kafkarest.entities.v3.ListConsumerGroupOffsetsResultsData

ListConsumerGroupOffsetsResultsData.Builder - Class in io.confluent.kafkarest.entities.v3

listDefaultTopicConfigs(AsyncResponse, String, String) - Method in class io.confluent.kafkarest.resources.v3.DefaultTopicConfigsResource

listDefaultTopicConfigs(String, String) - Method in interface io.confluent.kafkarest.controllers.DefaultTopicConfigManager

Returns the list of Kafka TopicConfigs belonging to the Topic with the given topicName.

listFromConsumerRecordList(List<ConsumerRecord<byte[], byte[]>>, Integer, boolean) - Static method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord

listGroupConfigs(AsyncResponse, String, String) - Method in class io.confluent.kafkarest.resources.v3.GroupConfigResource

listGroupConfigs(String, String) - Method in interface io.confluent.kafkarest.controllers.GroupConfigManager

Returns a list of Kafka GroupConfigs belonging to the group with the given groupId.

ListGroupConfigsResponse - Class in io.confluent.kafkarest.entities.v3

listLastProducedTimes(String) - Method in interface io.confluent.kafkarest.controllers.LastProducedTimeManager

Returns list of lastProducedTime for the last message produced for each topic in a given clusterId.

ListLastProducedTimesResponse - Class in io.confluent.kafkarest.entities.v3

listLinkConfigs(AsyncResponse, String, String) - Method in class io.confluent.kafkarest.resources.v3.LinkConfigResource

listLinkConfigs(String, String) - Method in interface io.confluent.kafkarest.controllers.LinkConfigManager

Returns a list of Kafka LinkConfigs belonging to the Link with the given LinkName.

ListLinkConfigsResponse - Class in io.confluent.kafkarest.entities.v3

listLinks(AsyncResponse, String) - Method in class io.confluent.kafkarest.resources.v3.LinkResource

listLinks(String) - Method in interface io.confluent.kafkarest.controllers.LinkManager

Returns the list of Kafka links belonging to the Cluster with the given clusterId.

ListLinksResponse - Class in io.confluent.kafkarest.entities.v3

ListLinksResponse() - Constructor for class io.confluent.kafkarest.entities.v3.ListLinksResponse

listMirrors(AsyncResponse, String, String, MirrorStatus) - Method in class io.confluent.kafkarest.resources.v3.MirrorResource

listMirrors(String, MirrorStatus) - Method in interface io.confluent.kafkarest.controllers.MirrorManager

Returns all Kafka mirrors in the cluster with the given clusterId, and in the given mirrorStatus.

listMirrors(String, String, MirrorStatus) - Method in interface io.confluent.kafkarest.controllers.MirrorManager

Returns all Kafka mirrors under the link with the given linkName, in the cluster with the given clusterId, and in the given mirrorStatus.

ListMirrorsResponse - Class in io.confluent.kafkarest.entities.v3

ListMirrorsResponse() - Constructor for class io.confluent.kafkarest.entities.v3.ListMirrorsResponse

listPartitionReplicaStatus(String, String, int) - Method in interface io.confluent.kafkarest.controllers.ReplicaStatusManager

Returns the list of Statuses for the Kafka Partition with the given clusterId, topicName and partitionId.

ListRemoveBrokerTaskResponse - Class in io.confluent.kafkarest.entities.v3

listRemoveBrokerTasks(AsyncResponse, String) - Method in class io.confluent.kafkarest.resources.v3.RemoveBrokerTaskResource

listRemoveBrokerTasks(String) - Method in interface io.confluent.kafkarest.controllers.RemoveBrokerTaskManager

Returns the list of Tasks for the Kafka Cluster with the given clusterId.

listReplicaStatus(AsyncResponse, String, String) - Method in class io.confluent.kafkarest.resources.v3.ReplicaStatusResource

listReplicaStatus(AsyncResponse, String, String, int) - Method in class io.confluent.kafkarest.resources.v3.ReplicaStatusByPartitionResource

ListReplicaStatusResponse - Class in io.confluent.kafkarest.entities.v3

listShareGroupAssignments(AsyncResponse, String, String, String) - Method in class io.confluent.kafkarest.resources.v3.ShareGroupConsumersResource

ListShareGroupAssignmentsResponse - Class in io.confluent.kafkarest.entities.v3

ListShareGroupAssignmentsResponse(ShareGroupConsumerAssignmentDataList) - Constructor for class io.confluent.kafkarest.entities.v3.ListShareGroupAssignmentsResponse

listShareGroupConsumers(AsyncResponse, String, String) - Method in class io.confluent.kafkarest.resources.v3.ShareGroupConsumersResource

ListShareGroupConsumersResponse - Class in io.confluent.kafkarest.entities.v3

listShareGroups(AsyncResponse, String) - Method in class io.confluent.kafkarest.resources.v3.ShareGroupsResource

listShareGroups(String) - Method in interface io.confluent.kafkarest.controllers.ShareGroupManager

Returns the list of Kafka Share Groups belonging to the Cluster with the given clusterId.

ListShareGroupsResponse - Class in io.confluent.kafkarest.entities.v3

listStreamsGroupAssignmentTasks(AsyncResponse, String, String, String, StreamsGroupMemberAssignment.AssignmentType) - Method in class io.confluent.kafkarest.resources.v3.StreamsGroupAssignmentsResource

listStreamsGroupMembers(AsyncResponse, String, String) - Method in class io.confluent.kafkarest.resources.v3.StreamsGroupMembersResource

ListStreamsGroupMembersResponse - Class in io.confluent.kafkarest.entities.v3

listStreamsGroups(AsyncResponse, String) - Method in class io.confluent.kafkarest.resources.v3.StreamsGroupsResource

listStreamsGroups(String) - Method in interface io.confluent.kafkarest.controllers.StreamsGroupManager

Returns the list of Kafka Streams Groups belonging to the Cluster with the given clusterId.

ListStreamsGroupsResponse - Class in io.confluent.kafkarest.entities.v3

listStreamsGroupSubtopologies(AsyncResponse, String, String) - Method in class io.confluent.kafkarest.resources.v3.StreamsGroupSubtopologiesResource

ListStreamsGroupSubtopologiesResponse - Class in io.confluent.kafkarest.entities.v3

listStreamsGroupTargetAssignmentTasks(AsyncResponse, String, String, String, StreamsGroupMemberAssignment.AssignmentType) - Method in class io.confluent.kafkarest.resources.v3.StreamsGroupAssignmentsResource

ListStreamsTasksResponse - Class in io.confluent.kafkarest.entities.v3

listTopicReplicaStatus(String, String) - Method in interface io.confluent.kafkarest.controllers.ReplicaStatusManager

Returns the list of Statuses for the Kafka Topic with the given clusterId, topicName.

LOG_APPEND_TIME - Enum constant in enum class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.TimestampType

See TimestampType.LOG_APPEND_TIME.

M

mapAlterOffsetExecutionExceptionToError(ExecutionException, TopicPartition, String) - Static method in class io.confluent.kafkarest.exceptions.ConsumerGroupOffsetsUtils

Maps ExecutionException, thrown while handling result of Admin.alterConsumerGroupOffsets(), to REST errors.

mapListOffsetExecutionExceptionToError(ExecutionException, TopicPartition, String) - Static method in class io.confluent.kafkarest.exceptions.ConsumerGroupOffsetsUtils

Maps ExecutionException, thrown while handling result of Admin.ListOffsets(), to REST errors.

MAX_POLL_RECORDS_LIMIT - Static variable in class io.confluent.kafkarest.resources.v3.SimpleConsumeAction

max_poll_records is the parameter that shows the maximum number of messages to be returned.

Mirror - Class in io.confluent.kafkarest.entities

MirrorData - Class in io.confluent.kafkarest.entities.v3

MirrorData.Builder - Class in io.confluent.kafkarest.entities.v3

MirrorDataList - Class in io.confluent.kafkarest.entities.v3

MirrorDataList.Builder - Class in io.confluent.kafkarest.entities.v3

MirrorInfoNotAvailableException - Exception Class in io.confluent.kafkarest.exceptions

An exception that indicates that the mirror info is not available in the replica status output.

MirrorInfoNotAvailableException(String) - Constructor for exception class io.confluent.kafkarest.exceptions.MirrorInfoNotAvailableException

MirrorLagData - Class in io.confluent.kafkarest.entities.v3

MirrorLagData.Builder - Class in io.confluent.kafkarest.entities.v3

MirrorManager - Interface in io.confluent.kafkarest.controllers

A service to manage Kafka mirrors.

MirrorResource - Class in io.confluent.kafkarest.resources.v3

MirrorResource(Provider<MirrorManager>, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.MirrorResource

MirrorStatus - Enum Class in io.confluent.kafkarest.entities

MirrorTopicNotFoundException - Exception Class in io.confluent.kafkarest.exceptions

An exception that indicates that the mirror topic doesn't exist.

MirrorTopicNotFoundException(String) - Constructor for exception class io.confluent.kafkarest.exceptions.MirrorTopicNotFoundException

MirrorTopicNotFoundException(Throwable) - Constructor for exception class io.confluent.kafkarest.exceptions.MirrorTopicNotFoundException

MirrorTopicNotFoundException(Collection<String>, Collection<String>) - Constructor for exception class io.confluent.kafkarest.exceptions.MirrorTopicNotFoundException

MultiTenantMetricsDosFilterListener - Class in io.confluent.kafkarest.metrics

MultiTenantMetricsDosFilterListener(Metrics, Map<String, String>, String) - Constructor for class io.confluent.kafkarest.metrics.MultiTenantMetricsDosFilterListener

MultiTenantUtils - Class in io.confluent.kafkarest.utils

N

NO_TIMESTAMP_TYPE - Enum constant in enum class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.TimestampType

See TimestampType.NO_TIMESTAMP_TYPE.

NOT_READY - Enum constant in enum class io.confluent.kafkarest.entities.StreamsGroup.State

O

OAuthBearerLoginWithIdentityPoolCallbackHandler - Class in io.confluent.kafkarest.auth

A CallbackHandler that recognizes OAuthBearerTokenCallback and retrieves OAuth 2 Bearer Token that was provided via the JAAS config.

OAuthBearerLoginWithIdentityPoolCallbackHandler() - Constructor for class io.confluent.kafkarest.auth.OAuthBearerLoginWithIdentityPoolCallbackHandler

OFFSET - Enum constant in enum class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsRequest.OffsetType

OK - Enum constant in enum class io.confluent.kafkarest.entities.HealthCheckStatus

Indicates that the service is healthy.

onFailure(ErrorInformation) - Method in class io.confluent.kafkarest.utils.ErrorServiceImpl

onRequestOverLimit(HttpServletRequest, DoSFilter.OverLimit, DoSFilter) - Method in class io.confluent.kafkarest.metrics.MultiTenantMetricsDosFilterListener

P

PartitionConsumeData - Class in io.confluent.kafkarest.entities.v3

PartitionConsumeData() - Constructor for class io.confluent.kafkarest.entities.v3.PartitionConsumeData

PartitionConsumeData.Builder - Class in io.confluent.kafkarest.entities.v3

PartitionConsumeRecord - Class in io.confluent.kafkarest.entities.v3

PartitionConsumeRecord() - Constructor for class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord

PartitionConsumeRecord.Builder - Class in io.confluent.kafkarest.entities.v3

PartitionConsumeRecord.ExceededFields - Class in io.confluent.kafkarest.entities.v3

PartitionConsumeRecord.Header - Class in io.confluent.kafkarest.entities.v3

PartitionConsumeRecord.TimestampType - Enum Class in io.confluent.kafkarest.entities.v3

PartitionOffset() - Constructor for class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest.PartitionOffset

PartitionOffsetData - Class in io.confluent.kafkarest.entities.v3

PartitionOffsetData() - Constructor for class io.confluent.kafkarest.entities.v3.PartitionOffsetData

PartitionOffsetData.Builder - Class in io.confluent.kafkarest.entities.v3

PartitionResult - Class in io.confluent.kafkarest.entities.v3

PartitionResult(int, Long, String) - Constructor for class io.confluent.kafkarest.entities.v3.PartitionResult

PartitionsOffsetsData - Class in io.confluent.kafkarest.entities.v3

PartitionsOffsetsData(long) - Constructor for class io.confluent.kafkarest.entities.v3.PartitionsOffsetsData

PartitionTruncationData - Class in io.confluent.kafkarest.entities.v3

PartitionTruncationData.Builder - Class in io.confluent.kafkarest.entities.v3

PartitionTruncationInfo - Class in io.confluent.kafkarest.entities.v3

PAUSED - Enum constant in enum class io.confluent.kafkarest.entities.MirrorStatus

PauseMirrorAction - Class in io.confluent.kafkarest.resources.v3

PauseMirrorAction(Provider<MirrorManager>, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.PauseMirrorAction

pauseMirrors(AsyncResponse, String, String, boolean, AlterMirrorsRequest) - Method in class io.confluent.kafkarest.resources.v3.PauseMirrorAction

pauseMirrors(String, String, Set<String>, String, boolean) - Method in interface io.confluent.kafkarest.controllers.MirrorManager

Pause the Kafka mirror

PENDING_MIRROR - Enum constant in enum class io.confluent.kafkarest.entities.MirrorStatus

PENDING_REPAIR - Enum constant in enum class io.confluent.kafkarest.entities.MirrorStatus

PENDING_RESTORE - Enum constant in enum class io.confluent.kafkarest.entities.MirrorStatus

PENDING_SETUP_FOR_RESTORE - Enum constant in enum class io.confluent.kafkarest.entities.MirrorStatus

PENDING_STOPPED - Enum constant in enum class io.confluent.kafkarest.entities.MirrorStatus

PENDING_SYNCHRONIZE - Enum constant in enum class io.confluent.kafkarest.entities.MirrorStatus

PREPARING_REBALANCE - Enum constant in enum class io.confluent.kafkarest.entities.ShareGroup.State

PREPARING_REBALANCE - Enum constant in enum class io.confluent.kafkarest.entities.StreamsGroup.State

PRODUCER_CACHE_CAPACITY_CONFIG - Static variable in class io.confluent.kafkarest.auth.KafkaProducerCacheImpl

PRODUCER_CACHE_DEFAULT_CAPACITY - Static variable in class io.confluent.kafkarest.auth.KafkaProducerCacheImpl

PRODUCER_CACHE_DEFAULT_VALIDITY_MILLIS - Static variable in class io.confluent.kafkarest.auth.KafkaProducerCacheImpl

PRODUCER_CACHE_IP_AWARE_ENABLE_CONFIG - Static variable in class io.confluent.kafkarest.CeKafkaRestConfig

PRODUCER_CACHE_IP_AWARE_ENABLE_DEFAULT - Static variable in class io.confluent.kafkarest.CeKafkaRestConfig

PRODUCER_CACHE_IP_AWARE_ENABLE_DOC - Static variable in class io.confluent.kafkarest.CeKafkaRestConfig

PRODUCER_CACHE_TRACKING_USAGE_REFCOUNT_ENABLE_CONFIG - Static variable in class io.confluent.kafkarest.auth.KafkaProducerCacheImpl

By disabling this flag, the Producer will be closed as soon as it is removed from the cache.

PRODUCER_CACHE_VALIDITY_MILLIS_CONFIG - Static variable in class io.confluent.kafkarest.auth.KafkaProducerCacheImpl

PromoteMirrorAction - Class in io.confluent.kafkarest.resources.v3

PromoteMirrorAction(Provider<MirrorManager>, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.PromoteMirrorAction

promoteMirrors(AsyncResponse, String, String, boolean, AlterMirrorsRequest) - Method in class io.confluent.kafkarest.resources.v3.PromoteMirrorAction

promoteMirrors(String, String, Set<String>, String, boolean) - Method in interface io.confluent.kafkarest.controllers.MirrorManager

Promote the Kafka mirror

provide(String, Map<String, Object>) - Method in class io.confluent.kafkarest.auth.KafkaProducerCacheImpl

provide(String, Map<String, Object>) - Method in interface io.confluent.kafkarest.backends.kafka.KafkaProducerCache

PROXY_PROTOCOL_CLIENT_VERSION - Static variable in class io.confluent.kafkarest.CeKafkaRestConfig

PROXY_PROTOCOL_CLIENT_VERSION_DEFAULT - Static variable in class io.confluent.kafkarest.CeKafkaRestConfig

PROXY_PROTOCOL_CLIENT_VERSION_DOC - Static variable in class io.confluent.kafkarest.CeKafkaRestConfig

R

RAW_DATA_PROPERTY - Static variable in class io.confluent.kafkarest.utils.SimpleConsumeKeyValueDeserializer

The name of the property containing the raw Base64-encoded data of the schema-encoded key or value.

RECONCILING - Enum constant in enum class io.confluent.kafkarest.entities.StreamsGroup.State

ReferenceCountingHolder<V> - Class in io.confluent.kafkarest.utils

ReferenceCountingHolder(V) - Constructor for class io.confluent.kafkarest.utils.ReferenceCountingHolder

register(Configurable<?>, KafkaRestConfig) - Method in class io.confluent.kafkarest.CloudKafkaRestResourceExtension

register(Configurable<?>, KafkaRestConfig) - Method in class io.confluent.kafkarest.InternalCloudKafkaRestResourceExtension

register(Configurable<?>, KafkaRestConfig) - Method in class io.confluent.kafkarest.KafkaRestResourceExtension

releaseConsumer(KafkaConsumer<K, V>) - Method in interface io.confluent.kafkarest.controllers.KafkaConsumerProvider

REMOVE_BROKER - Enum constant in enum class io.confluent.kafkarest.entities.BrokerTaskType

removeBroker(AsyncResponse, String, Integer, boolean) - Method in class io.confluent.kafkarest.resources.v3.ExtensionsBrokersResource

removeBroker(String, Integer, boolean) - Method in interface io.confluent.kafkarest.controllers.ExtensionsBrokerManager

Removes a kafka Broker with the given brokerId from the kafka Cluster with given clusterId with option to shut down brokers specified with shouldShutdown that defaults to true.

removeBrokers(AsyncResponse, String, boolean, RemoveBrokersRequest) - Method in class io.confluent.kafkarest.resources.v3.ExtensionsBrokerAction

removeBrokers(String, List<Integer>, boolean) - Method in interface io.confluent.kafkarest.controllers.ExtensionsBrokerManager

Remove multiple kafka Brokers specified with the given list of brokerIds from the kafka Cluster with given clusterId with option to shut down brokers specified with shouldShutdown that defaults to true.

RemoveBrokersRequest - Class in io.confluent.kafkarest.entities.v3

RemoveBrokersRequest.Builder - Class in io.confluent.kafkarest.entities.v3

RemoveBrokerTask - Class in io.confluent.kafkarest.entities

RemoveBrokerTaskData - Class in io.confluent.kafkarest.entities.v3

RemoveBrokerTaskData.Builder - Class in io.confluent.kafkarest.entities.v3

RemoveBrokerTaskDataList - Class in io.confluent.kafkarest.entities.v3

RemoveBrokerTaskDataList.Builder - Class in io.confluent.kafkarest.entities.v3

RemoveBrokerTaskManager - Interface in io.confluent.kafkarest.controllers

A service to manage RemoveBrokerTask.

RemoveBrokerTaskResource - Class in io.confluent.kafkarest.resources.v3

RemoveBrokerTaskResource(Provider<RemoveBrokerTaskManager>, CrnFactory, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.RemoveBrokerTaskResource

ReplicaStatus - Class in io.confluent.kafkarest.entities

ReplicaStatus.Builder - Class in io.confluent.kafkarest.entities

ReplicaStatusByPartitionResource - Class in io.confluent.kafkarest.resources.v3

ReplicaStatusByPartitionResource(Provider<ReplicaStatusManager>, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.ReplicaStatusByPartitionResource

ReplicaStatusData - Class in io.confluent.kafkarest.entities.v3

ReplicaStatusData.Builder - Class in io.confluent.kafkarest.entities.v3

ReplicaStatusDataList - Class in io.confluent.kafkarest.entities.v3

ReplicaStatusDataList.Builder - Class in io.confluent.kafkarest.entities.v3

ReplicaStatusManager - Interface in io.confluent.kafkarest.controllers

A service to manage ReplicaStatus.

ReplicaStatusResource - Class in io.confluent.kafkarest.resources.v3

ReplicaStatusResource(Provider<ReplicaStatusManager>, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.ReplicaStatusResource

REQUIRE_SECRETS_STORE_VALIDATION_CONFIG - Static variable in class io.confluent.kafkarest.auth.CloudExtensionsAuthFilter

resetGroupConfig(AsyncResponse, String, String, String) - Method in class io.confluent.kafkarest.resources.v3.GroupConfigResource

resetGroupConfig(String, String, String) - Method in interface io.confluent.kafkarest.controllers.GroupConfigManager

Resets the Kafka GroupConfig with the given name to its default value.

resetLinkConfig(AsyncResponse, String, String, String) - Method in class io.confluent.kafkarest.resources.v3.LinkConfigResource

resetLinkConfig(String, String, String) - Method in interface io.confluent.kafkarest.controllers.LinkConfigManager

Resets the Kafka LinkConfig with the given name to its default value.

ResetType - Enum Class in io.confluent.kafkarest.entities.v3

Enum representing the type of offset reset operation for share groups.

ResourceClosedException - Exception Class in io.confluent.kafkarest.exceptions

Exception thrown when attempting to use a producer that has been closed due to cache eviction.

ResourceClosedException(String) - Constructor for exception class io.confluent.kafkarest.exceptions.ResourceClosedException

ResourceClosedException(String, Throwable) - Constructor for exception class io.confluent.kafkarest.exceptions.ResourceClosedException

RestRequestProxyProtocolInfo - Class in io.confluent.kafkarest.auth

ResumeMirrorAction - Class in io.confluent.kafkarest.resources.v3

ResumeMirrorAction(Provider<MirrorManager>, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.ResumeMirrorAction

resumeMirrors(AsyncResponse, String, String, boolean, AlterMirrorsRequest) - Method in class io.confluent.kafkarest.resources.v3.ResumeMirrorAction

resumeMirrors(String, String, Set<String>, String, boolean) - Method in interface io.confluent.kafkarest.controllers.MirrorManager

Resume the Kafka mirror

reverseAndPauseMirrorAction(AsyncResponse, String, String, boolean, AlterMirrorsRequest) - Method in class io.confluent.kafkarest.resources.v3.ReverseAndPauseMirrorAction

ReverseAndPauseMirrorAction - Class in io.confluent.kafkarest.resources.v3

ReverseAndPauseMirrorAction(Provider<MirrorManager>, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.ReverseAndPauseMirrorAction

reverseAndPauseMirrors(String, String, Set<String>, String, boolean) - Method in interface io.confluent.kafkarest.controllers.MirrorManager

Reverse and Start the Kafka mirror

reverseAndStartMirrorAction(AsyncResponse, String, String, boolean, AlterMirrorsRequest) - Method in class io.confluent.kafkarest.resources.v3.ReverseAndStartMirrorAction

ReverseAndStartMirrorAction - Class in io.confluent.kafkarest.resources.v3

ReverseAndStartMirrorAction(Provider<MirrorManager>, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.ReverseAndStartMirrorAction

reverseAndStartMirrors(String, String, Set<String>, String, boolean) - Method in interface io.confluent.kafkarest.controllers.MirrorManager

Reverse and Start the Kafka mirror

S

serialize(EmbeddedFormat, String, Optional<RegisteredSchema>, JsonNode, boolean) - Method in class io.confluent.kafkarest.controllers.CloudRecordSerializerFacade

setActiveTasks(ImmutableList<StreamsTask>) - Method in class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment.Builder

setActiveTasks(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberAssignmentData.Builder

setAnyUnevenLoad(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.BalancerData.Builder

setAssignedPartitions(List<Partition>) - Method in class io.confluent.kafkarest.entities.ShareConsumer.Builder

setAssignedTopicPartitions(List<ShareGroupData.TopicPartitionData>) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.Builder

setAssignedTopicPartitions(List<TopicPartition>) - Method in class io.confluent.kafkarest.entities.ShareGroup.Builder

setAssignedTopicPartitionsWithOffsets(List<TopicPartitionWithOffset>) - Method in class io.confluent.kafkarest.entities.ShareGroup.Builder

setAssignment(StreamsGroupMemberAssignment) - Method in class io.confluent.kafkarest.entities.StreamsGroupMember.Builder

setAssignments(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerData.Builder

setAssignments(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData.Builder

setAuthorizedOperations(Set<AclOperation>) - Method in class io.confluent.kafkarest.entities.ShareGroup.Builder

setAuthorizedOperations(Set<AclOperation>) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.Builder

setBroker(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.AlterBrokerReplicaExclusionData.Builder

setBroker(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.BrokerRemovalData.Builder

setBroker(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionData.Builder

setBroker(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData.Builder

setBroker(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData.Builder

setBrokerId(int) - Method in class io.confluent.kafkarest.entities.AlterBrokerReplicaExclusion.Builder

setBrokerId(int) - Method in class io.confluent.kafkarest.entities.BrokerRemoval.Builder

setBrokerId(int) - Method in class io.confluent.kafkarest.entities.BrokerReplicaExclusion.Builder

setBrokerId(int) - Method in class io.confluent.kafkarest.entities.BrokerTask.Builder

setBrokerId(int) - Method in class io.confluent.kafkarest.entities.ReplicaStatus.Builder

setBrokerId(int) - Method in class io.confluent.kafkarest.entities.v3.AlterBrokerReplicaExclusionData.Builder

setBrokerId(int) - Method in class io.confluent.kafkarest.entities.v3.BrokerRemovalData.Builder

setBrokerId(int) - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionData.Builder

setBrokerId(int) - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionRequest.Builder

setBrokerId(int) - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData.Builder

setBrokerId(int) - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData.Builder

setBrokerId(int) - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData.Builder

setBrokerId(int) - Method in class io.confluent.kafkarest.entities.v3.UnregisterBrokerData.Builder

setBrokerIds(List<Integer>) - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokersRequest.Builder

setBrokerReplicaExclusionStatus(BrokerReplicaExclusionStatus) - Method in class io.confluent.kafkarest.entities.BrokerSubTaskStatuses.Builder

setBrokerReplicaExclusionStatus(BrokerReplicaExclusionStatus) - Method in class io.confluent.kafkarest.entities.v3.BrokerSubTaskStatusesData.Builder

setBrokerReplicaExclusionStatus(BrokerReplicaExclusionStatus) - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData.Builder

setBrokers(List<Integer>) - Method in class io.confluent.kafkarest.entities.v3.CellData.Builder

setBrokerShutdownStatus(BrokerShutdownStatus) - Method in class io.confluent.kafkarest.entities.BrokerSubTaskStatuses.Builder

setBrokerShutdownStatus(BrokerShutdownStatus) - Method in class io.confluent.kafkarest.entities.v3.BrokerSubTaskStatusesData.Builder

setBrokerShutdownStatus(BrokerShutdownStatus) - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData.Builder

setBrokerSubTaskStatuses(BrokerSubTaskStatuses) - Method in class io.confluent.kafkarest.entities.BrokerTask.Builder

setBrokerSubTaskStatuses(BrokerSubTaskStatusesData) - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData.Builder

setBrokerTask(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.BrokerRemovalData.Builder

setBrokerTasks(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData.Builder

setBrokerTasks(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.BalancerData.Builder

setBrokerTaskStatus(BalancerOperationStatus) - Method in class io.confluent.kafkarest.entities.BrokerTask.Builder

setBrokerTaskStatus(BalancerOperationStatus) - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData.Builder

setCategoryCounts(ImmutableList<LinkCategoryData>) - Method in class io.confluent.kafkarest.entities.v3.LinkData.Builder

setCategoryCounts(Map<ReplicaStatus.MirrorInfo.StateCategory, Integer>) - Method in class io.confluent.kafkarest.entities.Link.Builder

setCaughtUp(boolean) - Method in class io.confluent.kafkarest.entities.ReplicaStatus.Builder

setCaughtUp(boolean) - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData.Builder

setCellId(Integer) - Method in class io.confluent.kafkarest.entities.v3.CellData.Builder

setCells(List<CellData>) - Method in class io.confluent.kafkarest.entities.v3.CellStateData.Builder

setCells(List<DescribeCellsResponseData.Cell>) - Method in class io.confluent.kafkarest.entities.CellState.Builder

setCellsEnabled(Boolean) - Method in class io.confluent.kafkarest.entities.CellState.Builder

setCellsEnabled(Boolean) - Method in class io.confluent.kafkarest.entities.v3.CellStateData.Builder

setClientId(String) - Method in class io.confluent.kafkarest.entities.ShareConsumer.Builder

setClientId(String) - Method in class io.confluent.kafkarest.entities.StreamsGroupMember.Builder

setClientId(String) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerData.Builder

setClientId(String) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.AlterBrokerReplicaExclusion.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.Balancer.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.BalancerAnyUnevenLoadStatus.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.BrokerRemoval.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.BrokerReplicaExclusion.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.BrokerTask.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.CellState.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.ReplicaStatus.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.ShareConsumer.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.ShareGroup.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.StreamsGroup.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.StreamsGroupMember.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.StreamsGroupSubtopology.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.StreamsTask.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.AlterBrokerReplicaExclusionData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.BalancerData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.BrokerRemovalData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.CellStateData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.LastProducedTimeData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionResponse.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsMultiPartitionResponse.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsSinglePartitionResponse.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeSinglePartitionResponse.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberAssignmentData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupSubtopologyData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.StreamsTaskData.Builder

setClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.UnregisterBrokerData.Builder

setClusterLinkId(String) - Method in class io.confluent.kafkarest.entities.v3.CreateLinkRequest.Builder

setClusterLinkId(String) - Method in class io.confluent.kafkarest.entities.v3.LinkData.Builder

setClusterLinkId(Uuid) - Method in class io.confluent.kafkarest.entities.Link.Builder

setConfigs(List<CreateLinkRequest.ConfigEntry>) - Method in class io.confluent.kafkarest.entities.v3.CreateLinkRequest.Builder

setConfigs(List<CreateTopicRequest.ConfigEntry>) - Method in class io.confluent.kafkarest.entities.v3.CreateMirrorRequest.Builder

setConsumerCount(int) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.Builder

setConsumerGroupId(String) - Method in class io.confluent.kafkarest.entities.ShareConsumer.Builder

setConsumerGroupId(String) - Method in class io.confluent.kafkarest.entities.v3.ListConsumerGroupOffsetsResultsData.Builder

setConsumerId(String) - Method in class io.confluent.kafkarest.entities.ShareConsumer.Builder

setConsumerId(String) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentData.Builder

setConsumerId(String) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerData.Builder

setConsumers(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.Builder

setConsumers(List<ShareConsumer>) - Method in class io.confluent.kafkarest.entities.ShareGroup.Builder

setCoordinator(Broker) - Method in class io.confluent.kafkarest.entities.ShareGroup.Builder

setCoordinator(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.Builder

setCount(int) - Method in class io.confluent.kafkarest.entities.v3.LinkCategoryData.Builder

setCreatedAt(Instant) - Method in class io.confluent.kafkarest.entities.BrokerTask.Builder

setCreatedAt(Instant) - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData.Builder

setData(List<ShareGroupConsumerAssignmentData>) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentDataList.Builder

setDestinationClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.CreateLinkRequest.Builder

setDestinationClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.LinkData.Builder

setErrorCode(Integer) - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsData.Builder

setErrorCode(Short) - Method in class io.confluent.kafkarest.entities.AlterBrokerReplicaExclusion.Builder

setErrorCode(Short) - Method in class io.confluent.kafkarest.entities.Balancer.Builder

setErrorCode(Short) - Method in class io.confluent.kafkarest.entities.BalancerAnyUnevenLoadStatus.Builder

setErrorCode(Short) - Method in class io.confluent.kafkarest.entities.BrokerReplicaExclusion.Builder

setErrorCode(Short) - Method in class io.confluent.kafkarest.entities.BrokerTask.Builder

setErrorCode(Short) - Method in class io.confluent.kafkarest.entities.CellState.Builder

setErrorCode(Short) - Method in class io.confluent.kafkarest.entities.v3.AlterBrokerReplicaExclusionData.Builder

setErrorCode(Short) - Method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData.Builder

setErrorCode(Short) - Method in class io.confluent.kafkarest.entities.v3.BalancerData.Builder

setErrorCode(Short) - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionData.Builder

setErrorCode(Short) - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData.Builder

setErrorCode(Short) - Method in class io.confluent.kafkarest.entities.v3.CellStateData.Builder

setErrorCode(Short) - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData.Builder

setErrorCode(String) - Method in class io.confluent.kafkarest.entities.v3.LinkTaskErrorData.Builder

setErrorMessage(String) - Method in class io.confluent.kafkarest.entities.AlterBrokerReplicaExclusion.Builder

setErrorMessage(String) - Method in class io.confluent.kafkarest.entities.Balancer.Builder

setErrorMessage(String) - Method in class io.confluent.kafkarest.entities.BalancerAnyUnevenLoadStatus.Builder

setErrorMessage(String) - Method in class io.confluent.kafkarest.entities.BrokerReplicaExclusion.Builder

setErrorMessage(String) - Method in class io.confluent.kafkarest.entities.BrokerTask.Builder

setErrorMessage(String) - Method in class io.confluent.kafkarest.entities.CellState.Builder

setErrorMessage(String) - Method in class io.confluent.kafkarest.entities.v3.AlterBrokerReplicaExclusionData.Builder

setErrorMessage(String) - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsData.Builder

setErrorMessage(String) - Method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData.Builder

setErrorMessage(String) - Method in class io.confluent.kafkarest.entities.v3.BalancerData.Builder

setErrorMessage(String) - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionData.Builder

setErrorMessage(String) - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData.Builder

setErrorMessage(String) - Method in class io.confluent.kafkarest.entities.v3.CellStateData.Builder

setErrorMessage(String) - Method in class io.confluent.kafkarest.entities.v3.LinkTaskErrorData.Builder

setErrorMessage(String) - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData.Builder

setErrors(ImmutableList<LinkTaskErrorData>) - Method in class io.confluent.kafkarest.entities.v3.LinkTaskData.Builder

setExceededFields(PartitionConsumeRecord.ExceededFields) - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.Builder

setExclusion(ExclusionOp.OpType) - Method in class io.confluent.kafkarest.entities.AlterBrokerReplicaExclusion.Builder

setExclusion(ExclusionOp.OpType) - Method in class io.confluent.kafkarest.entities.v3.AlterBrokerReplicaExclusionData.Builder

setFetchMaxBytes(Integer) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest.Builder

setFromBeginning(Boolean) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest.Builder

setGroupEpoch(int) - Method in class io.confluent.kafkarest.entities.ShareGroup.Builder

setGroupEpoch(int) - Method in class io.confluent.kafkarest.entities.StreamsGroup.Builder

setGroupEpoch(int) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.Builder

setGroupEpoch(int) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData.Builder

setGroupId(String) - Method in class io.confluent.kafkarest.entities.GroupConfig.Builder

setGroupId(String) - Method in class io.confluent.kafkarest.entities.v3.GroupConfigData.Builder

setHeaders(List<PartitionConsumeRecord.Header>) - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.Builder

setHost(String) - Method in class io.confluent.kafkarest.entities.ShareConsumer.Builder

setInIsr(boolean) - Method in class io.confluent.kafkarest.entities.ReplicaStatus.Builder

setInIsr(boolean) - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData.Builder

setInstanceId(String) - Method in class io.confluent.kafkarest.entities.ShareConsumer.Builder

setInstanceId(Optional<String>) - Method in class io.confluent.kafkarest.entities.StreamsGroupMember.Builder

setInstanceId(Optional<String>) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData.Builder

setIsClassic(boolean) - Method in class io.confluent.kafkarest.entities.StreamsGroupMember.Builder

setIsClassic(boolean) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData.Builder

setIsrEligible(boolean) - Method in class io.confluent.kafkarest.entities.ReplicaStatus.Builder

setIsrEligible(boolean) - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData.Builder

setKey(Object) - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.Builder

setLag(Long) - Method in class io.confluent.kafkarest.entities.v3.MirrorLagData.Builder

setLastCaughtUpTimeMs(long) - Method in class io.confluent.kafkarest.entities.ReplicaStatus.Builder

setLastCaughtUpTimeMs(long) - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData.Builder

setLastFetchTimeMs(long) - Method in class io.confluent.kafkarest.entities.ReplicaStatus.Builder

setLastFetchTimeMs(long) - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData.Builder

setLastProducedTimeMs(long) - Method in class io.confluent.kafkarest.entities.v3.LastProducedTimeData.Builder

setLastSourceFetchHighWatermark(Long) - Method in class io.confluent.kafkarest.entities.v3.MirrorLagData.Builder

setLeader(boolean) - Method in class io.confluent.kafkarest.entities.ReplicaStatus.Builder

setLeader(boolean) - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData.Builder

setLinkError(String) - Method in class io.confluent.kafkarest.entities.v3.LinkData.Builder

setLinkError(ClusterLinkError) - Method in class io.confluent.kafkarest.entities.Link.Builder

setLinkErrorMessage(String) - Method in class io.confluent.kafkarest.entities.Link.Builder

setLinkErrorMessage(String) - Method in class io.confluent.kafkarest.entities.v3.LinkData.Builder

setLinkId(UUID) - Method in class io.confluent.kafkarest.entities.Link.Builder

setLinkId(UUID) - Method in class io.confluent.kafkarest.entities.v3.LinkData.Builder

setLinkMode(ClusterLinkDescription.LinkMode) - Method in class io.confluent.kafkarest.entities.Link.Builder

setLinkName(String) - Method in class io.confluent.kafkarest.entities.Link.Builder

setLinkName(String) - Method in class io.confluent.kafkarest.entities.LinkConfig.Builder

setLinkName(String) - Method in class io.confluent.kafkarest.entities.ReplicaStatus.Builder

setLinkName(String) - Method in class io.confluent.kafkarest.entities.v3.LinkConfigData.Builder

setLinkName(String) - Method in class io.confluent.kafkarest.entities.v3.LinkData.Builder

setLinkName(String) - Method in class io.confluent.kafkarest.entities.v3.MirrorData.Builder

setLinkName(String) - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData.Builder

setLinkState(String) - Method in class io.confluent.kafkarest.entities.v3.LinkData.Builder

setLinkState(ClusterLinkDescription.LinkState) - Method in class io.confluent.kafkarest.entities.Link.Builder

setLogEndOffset(long) - Method in class io.confluent.kafkarest.entities.ReplicaStatus.Builder

setLogEndOffset(long) - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData.Builder

setLogStartOffset(long) - Method in class io.confluent.kafkarest.entities.ReplicaStatus.Builder

setLogStartOffset(long) - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData.Builder

setMaxPollRecords(Integer) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest.Builder

setMemberCount(int) - Method in class io.confluent.kafkarest.entities.StreamsGroup.Builder

setMemberCount(int) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData.Builder

setMemberEpoch(int) - Method in class io.confluent.kafkarest.entities.StreamsGroupMember.Builder

setMemberEpoch(int) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData.Builder

setMemberId(String) - Method in class io.confluent.kafkarest.entities.StreamsGroupMember.Builder

setMemberId(String) - Method in class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment.Builder

setMemberId(String) - Method in class io.confluent.kafkarest.entities.StreamsTask.Builder

setMemberId(String) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberAssignmentData.Builder

setMemberId(String) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData.Builder

setMemberId(String) - Method in class io.confluent.kafkarest.entities.v3.StreamsTaskData.Builder

setMembers(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData.Builder

setMembers(List<StreamsGroupMember>) - Method in class io.confluent.kafkarest.entities.StreamsGroup.Builder

setMessageMaxBytes(Integer) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest.Builder

setMessagesTruncated(Long) - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsData.Builder

setMessagesTruncated(Long) - Method in class io.confluent.kafkarest.entities.v3.PartitionTruncationData.Builder

setMetadata(String) - Method in class io.confluent.kafkarest.entities.v3.TopicPartitionOffsetAndMetaData.Builder

setMirrorLags(ImmutableList<MirrorLagData>) - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsData.Builder

setMirrorLags(ImmutableList<MirrorLagData>) - Method in class io.confluent.kafkarest.entities.v3.MirrorData.Builder

setMirrorStateTransitionErrors(ImmutableList<LinkTaskErrorData>) - Method in class io.confluent.kafkarest.entities.v3.MirrorData.Builder

setMirrorStatus(String) - Method in class io.confluent.kafkarest.entities.v3.MirrorData.Builder

setMirrorTopicError(String) - Method in class io.confluent.kafkarest.entities.v3.MirrorData.Builder

setMirrorTopicName(String) - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsData.Builder

setMirrorTopicName(String) - Method in class io.confluent.kafkarest.entities.v3.CreateMirrorRequest.Builder

setMirrorTopicName(String) - Method in class io.confluent.kafkarest.entities.v3.MirrorData.Builder

setMirrorTopicNamePattern(String) - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsRequest.Builder

setMirrorTopicNames(ImmutableList<String>) - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsRequest.Builder

setNextOffset(Long) - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeData.Builder

setNextOffset(Long) - Method in class io.confluent.kafkarest.entities.v3.PartitionOffsetData.Builder

setNextOffset(Long) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsSinglePartitionResponse.Builder

setNumPartitions(int) - Method in class io.confluent.kafkarest.entities.v3.MirrorData.Builder

setObserver(boolean) - Method in class io.confluent.kafkarest.entities.ReplicaStatus.Builder

setObserver(boolean) - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData.Builder

setOffset(long) - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.Builder

setOffset(long) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest.PartitionOffset.Builder

setOffset(long) - Method in class io.confluent.kafkarest.entities.v3.TopicPartitionOffsetAndMetaData.Builder

setOffset(Long) - Method in class io.confluent.kafkarest.entities.TopicPartitionWithOffset.Builder

setOffset(Long) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.TopicPartitionData.Builder

setOffsets(List<SimpleConsumeMultiPartitionRequest.PartitionOffset>) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest.Builder

setOffsets(List<TopicPartitionOffsetAndMetaData>) - Method in class io.confluent.kafkarest.entities.v3.ListConsumerGroupOffsetsResultsData.Builder

setOffsetTruncatedTo(Long) - Method in class io.confluent.kafkarest.entities.v3.PartitionTruncationData.Builder

setOpenForTenantAssignment(Boolean) - Method in class io.confluent.kafkarest.entities.v3.CellData.Builder

setPartition(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentData.Builder

setPartition(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.TopicPartitionData.Builder

setPartition(Integer) - Method in class io.confluent.kafkarest.entities.v3.MirrorLagData.Builder

setPartitionCount(int) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.Builder

setPartitionData(PartitionConsumeData) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeSinglePartitionResponse.Builder

setPartitionDataList(List<PartitionConsumeData>) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionResponse.Builder

setPartitionId(int) - Method in class io.confluent.kafkarest.entities.ReplicaStatus.Builder

setPartitionId(int) - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.Builder

setPartitionId(int) - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData.Builder

setPartitionId(int) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentData.Builder

setPartitionId(int) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.TopicPartitionData.Builder

setPartitionId(int) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest.PartitionOffset.Builder

setPartitionId(Integer) - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeData.Builder

setPartitionId(Integer) - Method in class io.confluent.kafkarest.entities.v3.PartitionOffsetData.Builder

setPartitionId(Integer) - Method in class io.confluent.kafkarest.entities.v3.PartitionTruncationData.Builder

setPartitionId(Integer) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsSinglePartitionResponse.Builder

setPartitionId(Integer) - Method in class io.confluent.kafkarest.entities.v3.TopicPartitionOffsetAndMetaData.Builder

setPartitionIds(List<Integer>) - Method in class io.confluent.kafkarest.entities.StreamsTask.Builder

setPartitionIds(List<Integer>) - Method in class io.confluent.kafkarest.entities.v3.StreamsTaskData.Builder

setPartitionLevelTruncationData(ImmutableList<PartitionTruncationData>) - Method in class io.confluent.kafkarest.entities.v3.AlterMirrorsData.Builder

setPartitionOffsetList(List<PartitionOffsetData>) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsMultiPartitionResponse.Builder

setPartitionReassignmentStatus(PartitionReassignmentsStatus) - Method in class io.confluent.kafkarest.entities.BrokerSubTaskStatuses.Builder

setPartitionReassignmentStatus(PartitionReassignmentsStatus) - Method in class io.confluent.kafkarest.entities.v3.BrokerSubTaskStatusesData.Builder

setPartitionReassignmentStatus(PartitionReassignmentsStatus) - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData.Builder

setPreviousStatus(EvenClusterLoadStatus) - Method in class io.confluent.kafkarest.entities.BalancerAnyUnevenLoadStatus.Builder

setPreviousStatus(EvenClusterLoadStatus) - Method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData.Builder

setPreviousStatusUpdatedAt(Instant) - Method in class io.confluent.kafkarest.entities.BalancerAnyUnevenLoadStatus.Builder

setPreviousStatusUpdatedAt(Instant) - Method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData.Builder

setProcessId(String) - Method in class io.confluent.kafkarest.entities.StreamsGroupMember.Builder

setProcessId(String) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData.Builder

setReason(String) - Method in class io.confluent.kafkarest.entities.AlterBrokerReplicaExclusion.Builder

setReason(String) - Method in class io.confluent.kafkarest.entities.BrokerReplicaExclusion.Builder

setReason(String) - Method in class io.confluent.kafkarest.entities.v3.AlterBrokerReplicaExclusionData.Builder

setReason(String) - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionData.Builder

setReason(String) - Method in class io.confluent.kafkarest.entities.v3.BrokerReplicaExclusionRequest.Builder

setRecords(List<PartitionConsumeRecord>) - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeData.Builder

setRemoteClusterId(String) - Method in class io.confluent.kafkarest.entities.Link.Builder

setRemoteClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.CreateLinkRequest.Builder

setRemoteClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.LinkData.Builder

setRemoteLinkState(ClusterLinkDescription.LinkState) - Method in class io.confluent.kafkarest.entities.Link.Builder

setReplicationFactor(Short) - Method in class io.confluent.kafkarest.entities.v3.CreateMirrorRequest.Builder

setShareGroupId(String) - Method in class io.confluent.kafkarest.entities.ShareGroup.Builder

setShareGroupId(String) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentData.Builder

setShareGroupId(String) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerData.Builder

setShareGroupId(String) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.Builder

setShutdownScheduled(boolean) - Method in class io.confluent.kafkarest.entities.v3.RemoveBrokerTaskData.Builder

setShutdownScheduled(Boolean) - Method in class io.confluent.kafkarest.entities.BrokerTask.Builder

setShutdownScheduled(Boolean) - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData.Builder

setSourceClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.CreateLinkRequest.Builder

setSourceClusterId(String) - Method in class io.confluent.kafkarest.entities.v3.LinkData.Builder

setSourceTopicName(String) - Method in class io.confluent.kafkarest.entities.v3.CreateMirrorRequest.Builder

setSourceTopicName(String) - Method in class io.confluent.kafkarest.entities.v3.MirrorData.Builder

setSourceTopics(List<String>) - Method in class io.confluent.kafkarest.entities.StreamsGroupSubtopology.Builder

setSourceTopics(List<String>) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupSubtopologyData.Builder

setStandbyTasks(ImmutableList<StreamsTask>) - Method in class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment.Builder

setStandbyTasks(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberAssignmentData.Builder

setState(byte) - Method in class io.confluent.kafkarest.entities.v3.CellData.Builder

setState(ShareGroup.State) - Method in class io.confluent.kafkarest.entities.ShareGroup.Builder

setState(ShareGroup.State) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.Builder

setState(StreamsGroup.State) - Method in class io.confluent.kafkarest.entities.StreamsGroup.Builder

setState(StreamsGroup.State) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData.Builder

setState(String) - Method in class io.confluent.kafkarest.entities.v3.LinkTaskData.Builder

setStateCategory(ReplicaStatus.MirrorInfo.StateCategory) - Method in class io.confluent.kafkarest.entities.v3.LinkCategoryData.Builder

setStateTimeMs(long) - Method in class io.confluent.kafkarest.entities.v3.MirrorData.Builder

setStatus(BalancerStatus) - Method in class io.confluent.kafkarest.entities.Balancer.Builder

setStatus(BalancerStatus) - Method in class io.confluent.kafkarest.entities.v3.BalancerData.Builder

setStatus(EvenClusterLoadStatus) - Method in class io.confluent.kafkarest.entities.BalancerAnyUnevenLoadStatus.Builder

setStatus(EvenClusterLoadStatus) - Method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData.Builder

setStatusUpdatedAt(Instant) - Method in class io.confluent.kafkarest.entities.BalancerAnyUnevenLoadStatus.Builder

setStatusUpdatedAt(Instant) - Method in class io.confluent.kafkarest.entities.v3.BalancerAnyUnevenLoadStatusData.Builder

setStreamsGroupId(String) - Method in class io.confluent.kafkarest.entities.StreamsGroup.Builder

setStreamsGroupId(String) - Method in class io.confluent.kafkarest.entities.StreamsGroupMember.Builder

setStreamsGroupId(String) - Method in class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment.Builder

setStreamsGroupId(String) - Method in class io.confluent.kafkarest.entities.StreamsGroupSubtopology.Builder

setStreamsGroupId(String) - Method in class io.confluent.kafkarest.entities.StreamsTask.Builder

setStreamsGroupId(String) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData.Builder

setStreamsGroupId(String) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberAssignmentData.Builder

setStreamsGroupId(String) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData.Builder

setStreamsGroupId(String) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupSubtopologyData.Builder

setStreamsGroupId(String) - Method in class io.confluent.kafkarest.entities.v3.StreamsTaskData.Builder

setSubtopologies(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData.Builder

setSubtopologies(List<StreamsGroupSubtopology>) - Method in class io.confluent.kafkarest.entities.StreamsGroup.Builder

setSubtopologyCount(int) - Method in class io.confluent.kafkarest.entities.StreamsGroup.Builder

setSubtopologyCount(int) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData.Builder

setSubtopologyId(String) - Method in class io.confluent.kafkarest.entities.StreamsGroupSubtopology.Builder

setSubtopologyId(String) - Method in class io.confluent.kafkarest.entities.StreamsTask.Builder

setSubtopologyId(String) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupSubtopologyData.Builder

setSubtopologyId(String) - Method in class io.confluent.kafkarest.entities.v3.StreamsTaskData.Builder

setTargetAssignment(StreamsGroupMemberAssignment) - Method in class io.confluent.kafkarest.entities.StreamsGroupMember.Builder

setTargetAssignmentEpoch(int) - Method in class io.confluent.kafkarest.entities.ShareGroup.Builder

setTargetAssignmentEpoch(int) - Method in class io.confluent.kafkarest.entities.StreamsGroup.Builder

setTargetAssignmentEpoch(int) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.Builder

setTargetAssignmentEpoch(int) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData.Builder

setTargetAssignments(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData.Builder

setTaskName(String) - Method in class io.confluent.kafkarest.entities.v3.LinkTaskData.Builder

setTasks(ImmutableList<LinkTaskData>) - Method in class io.confluent.kafkarest.entities.v3.LinkData.Builder

setTasks(ImmutableList<ClusterLinkTaskDescription>) - Method in class io.confluent.kafkarest.entities.Link.Builder

setTaskType(BrokerTaskType) - Method in class io.confluent.kafkarest.entities.BrokerTask.Builder

setTaskType(BrokerTaskType) - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData.Builder

setTimestamp(long) - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.Builder

setTimestamp(Long) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest.Builder

setTimestampType(PartitionConsumeRecord.TimestampType) - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.Builder

setTopicName(String) - Method in class io.confluent.kafkarest.entities.ReplicaStatus.Builder

setTopicName(String) - Method in class io.confluent.kafkarest.entities.v3.LastProducedTimeData.Builder

setTopicName(String) - Method in class io.confluent.kafkarest.entities.v3.ReplicaStatusData.Builder

setTopicName(String) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupConsumerAssignmentData.Builder

setTopicName(String) - Method in class io.confluent.kafkarest.entities.v3.ShareGroupData.TopicPartitionData.Builder

setTopicName(String) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionResponse.Builder

setTopicName(String) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsMultiPartitionResponse.Builder

setTopicName(String) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsSinglePartitionResponse.Builder

setTopicName(String) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeSinglePartitionResponse.Builder

setTopicName(String) - Method in class io.confluent.kafkarest.entities.v3.TopicPartitionOffsetAndMetaData.Builder

setTopicPartition(TopicPartition) - Method in class io.confluent.kafkarest.entities.TopicPartitionWithOffset.Builder

setTopicPartitionOffsetRequests(List<UpdateConsumerGroupOffsetsRequest.TopicPartitionOffsetData>) - Method in class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsRequest.Builder

setTopics(ImmutableList<String>) - Method in class io.confluent.kafkarest.entities.Link.Builder

setTopics(ImmutableList<String>) - Method in class io.confluent.kafkarest.entities.v3.LinkData.Builder

setTopologyEpoch(int) - Method in class io.confluent.kafkarest.entities.StreamsGroup.Builder

setTopologyEpoch(int) - Method in class io.confluent.kafkarest.entities.StreamsGroupMember.Builder

setTopologyEpoch(int) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupData.Builder

setTopologyEpoch(int) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberData.Builder

setTotalRecords(Long) - Method in class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsMultiPartitionResponse.Builder

setUpdatedAt(Instant) - Method in class io.confluent.kafkarest.entities.BrokerTask.Builder

setUpdatedAt(Instant) - Method in class io.confluent.kafkarest.entities.v3.BrokerTaskData.Builder

setValue(Object) - Method in class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.Builder

setWarmupTasks(ImmutableList<StreamsTask>) - Method in class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment.Builder

setWarmupTasks(Resource.Relationship) - Method in class io.confluent.kafkarest.entities.v3.StreamsGroupMemberAssignmentData.Builder

ShareConsumer - Class in io.confluent.kafkarest.entities

ShareConsumer.Builder - Class in io.confluent.kafkarest.entities

ShareGroup - Class in io.confluent.kafkarest.entities

Represents a Kafka Share Group.

ShareGroup.Builder - Class in io.confluent.kafkarest.entities

ShareGroup.State - Enum Class in io.confluent.kafkarest.entities

ShareGroupConsumerAssignmentData - Class in io.confluent.kafkarest.entities.v3

ShareGroupConsumerAssignmentData.Builder - Class in io.confluent.kafkarest.entities.v3

ShareGroupConsumerAssignmentDataList - Class in io.confluent.kafkarest.entities.v3

ShareGroupConsumerAssignmentDataList.Builder - Class in io.confluent.kafkarest.entities.v3

ShareGroupConsumerData - Class in io.confluent.kafkarest.entities.v3

ShareGroupConsumerData.Builder - Class in io.confluent.kafkarest.entities.v3

ShareGroupConsumerDataList - Class in io.confluent.kafkarest.entities.v3

ShareGroupConsumerDataList.Builder - Class in io.confluent.kafkarest.entities.v3

ShareGroupConsumersResource - Class in io.confluent.kafkarest.resources.v3

ShareGroupConsumersResource(Provider<ShareGroupManager>, CrnFactory, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.ShareGroupConsumersResource

ShareGroupData - Class in io.confluent.kafkarest.entities.v3

ShareGroupData.Builder - Class in io.confluent.kafkarest.entities.v3

ShareGroupData.TopicPartitionData - Class in io.confluent.kafkarest.entities.v3

ShareGroupData.TopicPartitionData.Builder - Class in io.confluent.kafkarest.entities.v3

ShareGroupDataList - Class in io.confluent.kafkarest.entities.v3

ShareGroupDataList.Builder - Class in io.confluent.kafkarest.entities.v3

ShareGroupManager - Interface in io.confluent.kafkarest.controllers

A service to manage Kafka Share Groups.

ShareGroupOffsetsResource - Class in io.confluent.kafkarest.resources.v3

ShareGroupOffsetsResource(Provider<ShareGroupManager>) - Constructor for class io.confluent.kafkarest.resources.v3.ShareGroupOffsetsResource

ShareGroupsResource - Class in io.confluent.kafkarest.resources.v3

ShareGroupsResource(Provider<ShareGroupManager>, CrnFactory, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.ShareGroupsResource

shutdown() - Method in class io.confluent.kafkarest.auth.CloudKafkaRestContext

SimpleConsumeAction - Class in io.confluent.kafkarest.resources.v3

SimpleConsumeAction(Provider<TopicManager>, Provider<SimpleConsumeManager>) - Constructor for class io.confluent.kafkarest.resources.v3.SimpleConsumeAction

SimpleConsumeKeyValueDeserializer - Class in io.confluent.kafkarest.utils

SimpleConsumeKeyValueDeserializer() - Constructor for class io.confluent.kafkarest.utils.SimpleConsumeKeyValueDeserializer

SimpleConsumeManager - Interface in io.confluent.kafkarest.controllers

SimpleConsumeManagerImpl - Class in io.confluent.kafkarest.controllers

SimpleConsumeManagerImpl(KafkaConsumerProvider, ExecutorService) - Constructor for class io.confluent.kafkarest.controllers.SimpleConsumeManagerImpl

SimpleConsumeMultiPartitionRequest - Class in io.confluent.kafkarest.entities.v3

SimpleConsumeMultiPartitionRequest() - Constructor for class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest

SimpleConsumeMultiPartitionRequest.Builder - Class in io.confluent.kafkarest.entities.v3

SimpleConsumeMultiPartitionRequest.PartitionOffset - Class in io.confluent.kafkarest.entities.v3

SimpleConsumeMultiPartitionRequest.PartitionOffset.Builder - Class in io.confluent.kafkarest.entities.v3

SimpleConsumeMultiPartitionResponse - Class in io.confluent.kafkarest.entities.v3

SimpleConsumeMultiPartitionResponse() - Constructor for class io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionResponse

SimpleConsumeMultiPartitionResponse.Builder - Class in io.confluent.kafkarest.entities.v3

SimpleConsumeOffsetsMultiPartitionResponse - Class in io.confluent.kafkarest.entities.v3

SimpleConsumeOffsetsMultiPartitionResponse() - Constructor for class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsMultiPartitionResponse

SimpleConsumeOffsetsMultiPartitionResponse.Builder - Class in io.confluent.kafkarest.entities.v3

SimpleConsumeOffsetsSinglePartitionResponse - Class in io.confluent.kafkarest.entities.v3

SimpleConsumeOffsetsSinglePartitionResponse() - Constructor for class io.confluent.kafkarest.entities.v3.SimpleConsumeOffsetsSinglePartitionResponse

SimpleConsumeOffsetsSinglePartitionResponse.Builder - Class in io.confluent.kafkarest.entities.v3

SimpleConsumeSinglePartitionResponse - Class in io.confluent.kafkarest.entities.v3

SimpleConsumeSinglePartitionResponse() - Constructor for class io.confluent.kafkarest.entities.v3.SimpleConsumeSinglePartitionResponse

SimpleConsumeSinglePartitionResponse.Builder - Class in io.confluent.kafkarest.entities.v3

SOURCE_UNAVAILABLE - Enum constant in enum class io.confluent.kafkarest.entities.MirrorStatus

STABLE - Enum constant in enum class io.confluent.kafkarest.entities.ShareGroup.State

STABLE - Enum constant in enum class io.confluent.kafkarest.entities.StreamsGroup.State

STANDBY - Enum constant in enum class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment.AssignmentType

STOPPED - Enum constant in enum class io.confluent.kafkarest.entities.MirrorStatus

StreamsGroup - Class in io.confluent.kafkarest.entities

Represents a Kafka Streams Group.

StreamsGroup.Builder - Class in io.confluent.kafkarest.entities

StreamsGroup.State - Enum Class in io.confluent.kafkarest.entities

StreamsGroupAssignmentsResource - Class in io.confluent.kafkarest.resources.v3

StreamsGroupAssignmentsResource(Provider<StreamsGroupManager>, CrnFactory, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.StreamsGroupAssignmentsResource

StreamsGroupData - Class in io.confluent.kafkarest.entities.v3

StreamsGroupData.Builder - Class in io.confluent.kafkarest.entities.v3

StreamsGroupDataList - Class in io.confluent.kafkarest.entities.v3

StreamsGroupDataList.Builder - Class in io.confluent.kafkarest.entities.v3

StreamsGroupManager - Interface in io.confluent.kafkarest.controllers

A service to manage Kafka Streams Groups.

StreamsGroupMember - Class in io.confluent.kafkarest.entities

StreamsGroupMember.Builder - Class in io.confluent.kafkarest.entities

StreamsGroupMemberAssignment - Class in io.confluent.kafkarest.entities

Represents a Kafka Streams Group.

StreamsGroupMemberAssignment.AssignmentType - Enum Class in io.confluent.kafkarest.entities

StreamsGroupMemberAssignment.Builder - Class in io.confluent.kafkarest.entities

StreamsGroupMemberAssignmentData - Class in io.confluent.kafkarest.entities.v3

StreamsGroupMemberAssignmentData.Builder - Class in io.confluent.kafkarest.entities.v3

StreamsGroupMemberData - Class in io.confluent.kafkarest.entities.v3

StreamsGroupMemberData.Builder - Class in io.confluent.kafkarest.entities.v3

StreamsGroupMemberDataList - Class in io.confluent.kafkarest.entities.v3

StreamsGroupMemberDataList.Builder - Class in io.confluent.kafkarest.entities.v3

StreamsGroupMembersResource - Class in io.confluent.kafkarest.resources.v3

StreamsGroupMembersResource(Provider<StreamsGroupManager>, CrnFactory, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.StreamsGroupMembersResource

StreamsGroupsResource - Class in io.confluent.kafkarest.resources.v3

StreamsGroupsResource(Provider<StreamsGroupManager>, CrnFactory, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.StreamsGroupsResource

StreamsGroupSubtopologiesResource - Class in io.confluent.kafkarest.resources.v3

StreamsGroupSubtopologiesResource(Provider<StreamsGroupManager>, CrnFactory, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.StreamsGroupSubtopologiesResource

StreamsGroupSubtopology - Class in io.confluent.kafkarest.entities

StreamsGroupSubtopology.Builder - Class in io.confluent.kafkarest.entities

StreamsGroupSubtopologyData - Class in io.confluent.kafkarest.entities.v3

StreamsGroupSubtopologyData.Builder - Class in io.confluent.kafkarest.entities.v3

StreamsGroupSubtopologyDataList - Class in io.confluent.kafkarest.entities.v3

StreamsGroupSubtopologyDataList.Builder - Class in io.confluent.kafkarest.entities.v3

StreamsTask - Class in io.confluent.kafkarest.entities

StreamsTask.Builder - Class in io.confluent.kafkarest.entities

StreamsTaskData - Class in io.confluent.kafkarest.entities.v3

StreamsTaskData.Builder - Class in io.confluent.kafkarest.entities.v3

StreamsTaskDataList - Class in io.confluent.kafkarest.entities.v3

StreamsTaskDataList.Builder - Class in io.confluent.kafkarest.entities.v3

T

TENANT_LEVEL_RATE_LIMIT_METRICS_ENABLED - Static variable in class io.confluent.kafkarest.CeKafkaRestConfig

TimeoutException - Exception Class in io.confluent.kafkarest.exceptions

An exception that indicates that the AdminClient request timed out

TimeoutException(String, Throwable) - Constructor for exception class io.confluent.kafkarest.exceptions.TimeoutException

TimeoutException(Throwable) - Constructor for exception class io.confluent.kafkarest.exceptions.TimeoutException

toGroupState() - Method in enum class io.confluent.kafkarest.entities.ShareGroup.State

toGroupState() - Method in enum class io.confluent.kafkarest.entities.StreamsGroup.State

TOPIC_UNAUTHORIZED_ERROR_MSG_ALTER_OFFSETS_TMPL - Static variable in class io.confluent.kafkarest.exceptions.ConsumerGroupOffsetsUtils

TopicPartitionLag - Class in io.confluent.kafkarest.entities

TopicPartitionNotFoundException - Exception Class in io.confluent.kafkarest.exceptions

An exception that indicates a fetch Kafka topic partition operation has been attempted for a non existing topic partition.

TopicPartitionNotFoundException(String, String, String) - Constructor for exception class io.confluent.kafkarest.exceptions.TopicPartitionNotFoundException

TopicPartitionNotFoundException(String, String, Optional<Integer>, String) - Constructor for exception class io.confluent.kafkarest.exceptions.TopicPartitionNotFoundException

TopicPartitionOffsetAndMetaData - Class in io.confluent.kafkarest.entities.v3

TopicPartitionOffsetAndMetaData() - Constructor for class io.confluent.kafkarest.entities.v3.TopicPartitionOffsetAndMetaData

TopicPartitionOffsetAndMetaData.Builder - Class in io.confluent.kafkarest.entities.v3

TopicPartitionWithOffset - Class in io.confluent.kafkarest.entities

Represents a TopicPartition with its associated offset and metadata.

TopicPartitionWithOffset.Builder - Class in io.confluent.kafkarest.entities

toResponse(AuthenticationException) - Method in class io.confluent.kafkarest.exceptions.AuthenticationExceptionMapper

toResponse(ClusterLinkDisabledException) - Method in class io.confluent.kafkarest.exceptions.ClusterLinkDisabledExceptionMapper

toResponse(ClusterLinkInUseException) - Method in class io.confluent.kafkarest.exceptions.ClusterLinkInUseExceptionMapper

toString() - Method in class io.confluent.kafkarest.auth.CloudPrincipal

toString() - Method in class io.confluent.kafkarest.entities.v3.AlterShareGroupOffsetsRequest

toString() - Method in class io.confluent.kafkarest.entities.v3.AlterShareGroupOffsetsResponse

toString() - Method in class io.confluent.kafkarest.entities.v3.PartitionResult

truncateAndRestoreMirrorAction(AsyncResponse, String, String, boolean, boolean, AlterMirrorsRequest) - Method in class io.confluent.kafkarest.resources.v3.TruncateAndRestoreMirrorAction

TruncateAndRestoreMirrorAction - Class in io.confluent.kafkarest.resources.v3

TruncateAndRestoreMirrorAction(Provider<MirrorManager>, UrlFactory) - Constructor for class io.confluent.kafkarest.resources.v3.TruncateAndRestoreMirrorAction

truncateAndRestoreMirrors(String, String, Set<String>, String, boolean, boolean) - Method in interface io.confluent.kafkarest.controllers.MirrorManager

Truncate and Restore the Kafka mirror

U

UIInternalModule - Class in io.confluent.kafkarest.controllers

UIInternalModule() - Constructor for class io.confluent.kafkarest.controllers.UIInternalModule

UIInternalModule.SimpleConsumeExecutor - Annotation Interface in io.confluent.kafkarest.controllers

UIInternalResourcesFeature - Class in io.confluent.kafkarest.resources.v3

Following APIs are called only on the cloud UI, hence "internal".

UIInternalResourcesFeature() - Constructor for class io.confluent.kafkarest.resources.v3.UIInternalResourcesFeature

UNAUTHORIZED_ERROR_MSG_ALTER_OFFSETS_TMPL - Static variable in class io.confluent.kafkarest.exceptions.ConsumerGroupOffsetsUtils

UNAUTHORIZED_ERROR_MSG_LIST_OFFSETS_TMPL - Static variable in class io.confluent.kafkarest.exceptions.ConsumerGroupOffsetsUtils

UNKNOWN - Enum constant in enum class io.confluent.kafkarest.entities.HealthCheckStatus

Indicates that the health check couldn't determine the health of the service.

UNKNOWN - Enum constant in enum class io.confluent.kafkarest.entities.MirrorStatus

UNKNOWN - Enum constant in enum class io.confluent.kafkarest.entities.ShareGroup.State

UNKNOWN - Enum constant in enum class io.confluent.kafkarest.entities.StreamsGroup.State

unregisterBroker(AsyncResponse, String, Integer) - Method in class io.confluent.kafkarest.resources.v3.ExtensionsBrokersResource

unregisterBroker(String, Integer) - Method in interface io.confluent.kafkarest.controllers.ExtensionsBrokerManager

Unregister the given broker from the cluster.

UnregisterBrokerData - Class in io.confluent.kafkarest.entities.v3

UnregisterBrokerData.Builder - Class in io.confluent.kafkarest.entities.v3

UnregisterBrokerResponse - Class in io.confluent.kafkarest.entities.v3

UnrepresentableBrokerIdException - Exception Class in io.confluent.kafkarest.exceptions

An exception that indicates the broker id is not unrepresentable or is invalid, e.g a negative number.

UnrepresentableBrokerIdException(Exception) - Constructor for exception class io.confluent.kafkarest.exceptions.UnrepresentableBrokerIdException

UNSUPPORTED_VERSION_ERROR_CODE - Static variable in class io.confluent.kafkarest.exceptions.ErrorCodes

UnsupportedVersionException - Exception Class in io.confluent.kafkarest.exceptions

An exception that indicates the underlying API is not supported by Kafka.

UnsupportedVersionException(String) - Constructor for exception class io.confluent.kafkarest.exceptions.UnsupportedVersionException

updateConsumerGroupOffset(AsyncResponse, String, String, UpdateConsumerGroupOffsetsRequest) - Method in class io.confluent.kafkarest.resources.v3.ConsumerGroupOffsetsResource

updateConsumerGroupOffsets(String, UpdateConsumerGroupOffsetsRequest) - Method in interface io.confluent.kafkarest.controllers.ConsumerGroupOffsetsManager

updateConsumerGroupOffsets(String, UpdateConsumerGroupOffsetsRequest) - Method in class io.confluent.kafkarest.controllers.ConsumerGroupOffsetsManagerImpl

UpdateConsumerGroupOffsetsRequest - Class in io.confluent.kafkarest.entities.v3

UpdateConsumerGroupOffsetsRequest.Builder - Class in io.confluent.kafkarest.entities.v3

UpdateConsumerGroupOffsetsRequest.OffsetData - Class in io.confluent.kafkarest.entities.v3

UpdateConsumerGroupOffsetsRequest.OffsetType - Enum Class in io.confluent.kafkarest.entities.v3

UpdateConsumerGroupOffsetsRequest.TopicPartitionOffsetData - Class in io.confluent.kafkarest.entities.v3

UpdateConsumerGroupOffsetsResponse - Class in io.confluent.kafkarest.entities.v3

UpdateConsumerGroupOffsetsResponse.TopicPartitionResponse - Class in io.confluent.kafkarest.entities.v3

updateGroupConfig(AsyncResponse, String, String, String, UpdateGroupConfigRequest) - Method in class io.confluent.kafkarest.resources.v3.GroupConfigResource

updateGroupConfig(String, String, String, String) - Method in interface io.confluent.kafkarest.controllers.GroupConfigManager

Updates the Kafka GroupConfig with the given name to the given newValue.

UpdateGroupConfigRequest - Class in io.confluent.kafkarest.entities.v3

updateLinkConfig(AsyncResponse, String, String, String, UpdateLinkConfigRequest) - Method in class io.confluent.kafkarest.resources.v3.LinkConfigResource

updateLinkConfig(String, String, String, String) - Method in interface io.confluent.kafkarest.controllers.LinkConfigManager

Updates the Kafka LinkConfig with the given name to the given newValue.

UpdateLinkConfigRequest - Class in io.confluent.kafkarest.entities.v3

USE_PROXY_PROTOCOL_WITH_BROKER - Static variable in class io.confluent.kafkarest.CeKafkaRestConfig

USE_PROXY_PROTOCOL_WITH_BROKER_DEFAULT - Static variable in class io.confluent.kafkarest.CeKafkaRestConfig

USE_PROXY_PROTOCOL_WITH_BROKER_DOC - Static variable in class io.confluent.kafkarest.CeKafkaRestConfig

V

VALIDATE_CLUSTER_ID_IN_URL_CONFIG - Static variable in class io.confluent.kafkarest.auth.CloudExtensionsAuthFilter

validateFipsForListeners(Map<String, Object>) - Method in class io.confluent.kafkarest.utils.CeKafkaRestFipsValidator

validateFipsInstanceConfigs(KafkaRestConfig) - Method in class io.confluent.kafkarest.utils.CeKafkaRestFipsValidator

valueOf(String) - Static method in enum class io.confluent.kafkarest.entities.BrokerTaskType

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafkarest.entities.HealthCheckStatus

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafkarest.entities.MirrorStatus

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafkarest.entities.ShareGroup.State

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafkarest.entities.StreamsGroup.State

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment.AssignmentType

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.TimestampType

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafkarest.entities.v3.ResetType

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsRequest.OffsetType

Returns the enum constant of this class with the specified name.

values() - Static method in enum class io.confluent.kafkarest.entities.BrokerTaskType

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafkarest.entities.HealthCheckStatus

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafkarest.entities.MirrorStatus

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafkarest.entities.ShareGroup.State

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafkarest.entities.StreamsGroup.State

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment.AssignmentType

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafkarest.entities.v3.PartitionConsumeRecord.TimestampType

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafkarest.entities.v3.ResetType

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafkarest.entities.v3.UpdateConsumerGroupOffsetsRequest.OffsetType

Returns an array containing the constants of this enum class, in the order they are declared.

W

WARMUP - Enum constant in enum class io.confluent.kafkarest.entities.StreamsGroupMemberAssignment.AssignmentType

WARNING - Enum constant in enum class io.confluent.kafkarest.entities.HealthCheckStatus

Indicates that there are some problems with the service.

A B C D E F G H I J K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form