Index (ce-odyssey 8.4.0-ce API)

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

accept(BiConsumer) - Method in class io.confluent.rm.api.RmWatcher.ContinueFromEnd
accept(BiConsumer) - Method in class io.confluent.rm.api.RmWatcher.ContinueWithToken
accept(BiConsumer) - Method in interface io.confluent.rm.api.RmWatcher.InitializationStrategy: Apply the given consumer with the appropriate continueToken and includeSnapshot values.
accept(BiConsumer) - Method in class io.confluent.rm.api.RmWatcher.LoadSnapshot
acquireToken(KafkaPrincipal) - Method in interface io.confluent.kafka.odyssey.OdysseyRequestManager: Acquires a Logical Access Token (LAT) from Token Platform for SR authentication.
addFinalizer(InternalSwitchoverPair, String) - Method in class io.confluent.rm.kafka.v1.RmIspStatusReporter
addFinalizer(T, String) - Method in interface io.confluent.rm.kafka.v1.RmStatusReporter: Adds a finalizer to the resource's metadata.
apply(List, boolean) - Method in interface io.confluent.kafka.odyssey.ExternalSchemaUpdater
apply(Map, boolean) - Method in interface io.confluent.kafka.odyssey.ControllerConfigUpdater
ASSOCIATE - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.Stage
AssociationConfig - Record Class in io.confluent.kafka.odyssey: Configuration for a schema association (key or value).
AssociationConfig(AssociationType, Optional, Optional, Optional, Optional, Optional, Optional, Optional, Optional, Optional, Optional) - Constructor for record class io.confluent.kafka.odyssey.AssociationConfig: Creates an instance of a AssociationConfig record class.
AssociationConfig.Builder - Class in io.confluent.kafka.odyssey
AssociationConfigParser - Class in io.confluent.kafka.odyssey: Parser for Odyssey association configurations
associationDeleted() - Method in record class io.confluent.kafka.odyssey.DeleteResult: Returns the value of the associationDeleted record component.
associationList() - Method in record class io.confluent.kafka.odyssey.TopicAssociationInfo
AssociationPayload - Class in io.confluent.kafka.odyssey: Jackson-deserialisable representation of the JSON value supplied by the user for confluent.key.association / confluent.value.association config keys.
AssociationPayload() - Constructor for class io.confluent.kafka.odyssey.AssociationPayload
AssociationResult - Record Class in io.confluent.kafka.odyssey
AssociationResult(KafkaResult) - Constructor for record class io.confluent.kafka.odyssey.AssociationResult: Creates an instance of a AssociationResult record class.
associationResults() - Method in record class io.confluent.kafka.odyssey.DescribeConfigsOdysseyResult: Returns the value of the associationResults record component.
associations() - Method in record class io.confluent.kafka.odyssey.TopicAssociationInfo: Returns the value of the associations record component.
associationType() - Method in record class io.confluent.kafka.odyssey.AssociationConfig: Returns the value of the associationType record component.
AssociationType - Enum Class in io.confluent.kafka.odyssey: Which side of a record an association applies to: key or value.
authenticatedPrincipalCrn() - Method in record class io.confluent.kafka.odyssey.auth.TokenRequestContext: Returns the value of the authenticatedPrincipalCrn record component.
authenticationError(String, Throwable) - Static method in exception class io.confluent.kafka.odyssey.auth.TokenPlatformException: Creates an exception for authentication/permission failures.
authMode() - Method in record class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig: Returns the value of the authMode record component.

B

brokerNamespace() - Method in record class io.confluent.rm.api.RmConfig: Returns the value of the brokerNamespace record component.
brokerServiceAccountId() - Method in record class io.confluent.rm.api.RmConfig: Returns the value of the brokerServiceAccountId record component.
build() - Method in class io.confluent.kafka.odyssey.AssociationConfig.Builder
build() - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager.Builder
buildAuthenticatedPrincipalCrn(String, String, String) - Static method in class io.confluent.kafka.odyssey.auth.KafkaClusterCrnBuilder: Builds a Kafka Logical Cluster CRN for use as the authenticated principal.
buildClient() - Method in interface io.confluent.rm.api.RmClientFactory
builder(AssociationType) - Static method in record class io.confluent.kafka.odyssey.AssociationConfig: Returns a builder with associationType set; all other fields default to empty.
Builder() - Constructor for class io.confluent.kafka.odyssey.OdysseyIntegrationManager.Builder
buildRawClient() - Method in interface io.confluent.rm.api.RmRawClientFactory: Builds a raw Resource Manager client.

C

classification() - Method in record class io.confluent.kafka.odyssey.ClassifyResult: Returns the value of the classification record component.
classification() - Method in record class io.confluent.kafka.odyssey.ValidationResult
classified() - Method in record class io.confluent.kafka.odyssey.ValidationContext: Returns the value of the classified record component.
classified(int, String) - Static method in record class io.confluent.kafka.odyssey.OdysseyResult: Per-topic Schema Registry outcome classified by HTTP-status family (see SchemaErrorClassifier): a 4xx caller fault (e.g.
ClassifyResult - Record Class in io.confluent.kafka.odyssey: Result of topic classification before token acquisition.
ClassifyResult(OdysseyRequestContext, TopicClassification, Map, Map) - Constructor for record class io.confluent.kafka.odyssey.ClassifyResult: Creates an instance of a ClassifyResult record class.
CLIENT_ERROR - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.ErrorClass
close() - Method in interface io.confluent.kafka.odyssey.auth.TokenPlatformClient: Closes the client and releases any resources (e.g., gRPC channels).
close() - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager: Closes this manager and releases all resources.
close() - Method in interface io.confluent.kafka.odyssey.OdysseyRequestManager: Gracefully shuts down the manager, cleaning up resources.
close() - Method in class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics
close() - Method in class io.confluent.kafka.odyssey.SchemaManagementRequestTypeMetrics
close() - Method in interface io.confluent.rm.api.RmClientFactory
close() - Method in interface io.confluent.rm.api.RmSubscription
ClusterlinkApi - Class in io.confluent.rm.clusterlink.v1: Clusterlink API client using the RM Java client with protobuf-based models.
ClusterlinkApi(Client) - Constructor for class io.confluent.rm.clusterlink.v1.ClusterlinkApi
code() - Method in enum class io.confluent.kafka.odyssey.OdysseyConstants.ErrorCodes
completionHandler(Runnable) - Method in interface io.confluent.rm.api.RmWatcher
CONFIGURATION - Enum constant in enum class io.confluent.kafka.odyssey.auth.TokenPlatformException.ErrorType: Configuration errors that require fixing before retry.
configurationError(String) - Static method in exception class io.confluent.kafka.odyssey.auth.TokenPlatformException: Creates an exception for configuration problems without a cause.
configurationError(String, Throwable) - Static method in exception class io.confluent.kafka.odyssey.auth.TokenPlatformException: Creates an exception for configuration problems.
ContinueFromEnd() - Constructor for class io.confluent.rm.api.RmWatcher.ContinueFromEnd
ContinueWithToken(String) - Constructor for class io.confluent.rm.api.RmWatcher.ContinueWithToken
ControllerConfigUpdater - Interface in io.confluent.kafka.odyssey: Callback that applies stripped config changes via the Kafka controller.
create(String, String) - Static method in record class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig: Creates a configuration for SPIRE agent mode with default timeout and retry settings.
create(T) - Method in interface io.confluent.rm.api.RmClient
CREATE - Enum constant in enum class io.confluent.kafka.odyssey.OdysseyRequestManager.RequestOp
CREATE_TOPICS - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementRequestTypeMetrics.RequestType
createAssociations(List, boolean, SchemaRegistryClient) - Method in interface io.confluent.kafka.odyssey.OdysseyRequestManager: Creates associations with Odyssey.
created() - Method in record class io.confluent.kafka.odyssey.AssociationResult: Returns the value of the created record component.
createDeletedTopic(DeletedTopic) - Method in interface io.confluent.rm.kafka.v1.RmTopicClient: Creates a deleted topic record to track the deletion of a topic.
createDeletedTopic(DeletedTopic) - Method in class io.confluent.rm.kafka.v1.RmTopicClientImpl
createGroupConfig(GroupConfig) - Method in interface io.confluent.rm.kafka.v1.RmGroupConfigClient: Creates a new GroupConfig resource for an Group.
createGroupConfig(GroupConfig) - Method in class io.confluent.rm.kafka.v1.RmGroupConfigClientImpl
createHealthProbe(HealthProbe) - Method in interface io.confluent.rm.kafka.v1.RmHealthProbeClient: Creates a new HealthProbe resource in the resource manager.
createHealthProbe(HealthProbe) - Method in class io.confluent.rm.kafka.v1.RmHealthProbeClientImpl
createStreamsTopology(StreamsTopology) - Method in interface io.confluent.rm.kafka.v1.RmStreamsTopologyClient: Creates a new StreamsTopology resource.
createStreamsTopology(StreamsTopology) - Method in class io.confluent.rm.kafka.v1.RmStreamsTopologyClientImpl
createTopic(Topic) - Method in interface io.confluent.rm.kafka.v1.RmTopicClient: Creates a new topic in the resource manager.
createTopic(Topic) - Method in class io.confluent.rm.kafka.v1.RmTopicClientImpl
createWithK8sSecret(String, String, String, String) - Static method in record class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig: Creates a configuration for SPIRE K8s-secret mode with default timeout and retry settings.

D

DEFAULT_MAX_RETRIES - Static variable in record class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig: Default max retries: 3 attempts
DEFAULT_REQUEST_TIMEOUT_MS - Static variable in record class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig: Default request timeout: 5 seconds
delete(ObjectIdentifier) - Method in interface io.confluent.rm.api.RmClient
DELETE_ASSOC - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.Stage
DELETE_TOPICS - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementRequestTypeMetrics.RequestType
deleteAssociations(Map, String, SchemaRegistryClient) - Method in interface io.confluent.kafka.odyssey.OdysseyRequestManager: Deletes associations for the given topics from Schema Registry.
deleteDeletedTopic(ObjectIdentifier) - Method in interface io.confluent.rm.kafka.v1.RmTopicClient: Removes a deleted topic record from the resource manager.
deleteDeletedTopic(ObjectIdentifier) - Method in class io.confluent.rm.kafka.v1.RmTopicClientImpl
deletedTopicWatch() - Method in interface io.confluent.rm.kafka.v1.RmTopicClient: Creates a watcher for monitoring deleted topic record changes in the resource manager.
deletedTopicWatch() - Method in class io.confluent.rm.kafka.v1.RmTopicClientImpl
deleteFinalizer(InternalSwitchoverPair, String) - Method in class io.confluent.rm.kafka.v1.RmIspStatusReporter
deleteFinalizer(T, String) - Method in interface io.confluent.rm.kafka.v1.RmStatusReporter: Removes a finalizer from the resource's metadata, allowing deletion to proceed once all finalizers have been removed.
deleteGroupConfig(ObjectIdentifier) - Method in interface io.confluent.rm.kafka.v1.RmGroupConfigClient: Deletes the GroupConfig resource for a Group.
deleteGroupConfig(ObjectIdentifier) - Method in class io.confluent.rm.kafka.v1.RmGroupConfigClientImpl
deleteHealthProbe(ObjectIdentifier) - Method in interface io.confluent.rm.kafka.v1.RmHealthProbeClient: Deletes a HealthProbe resource from the resource manager.
deleteHealthProbe(ObjectIdentifier) - Method in class io.confluent.rm.kafka.v1.RmHealthProbeClientImpl
DeleteResult - Record Class in io.confluent.kafka.odyssey: Per-topic outcome of an Odyssey delete request.
DeleteResult(Uuid, String, OdysseyResult, boolean) - Constructor for record class io.confluent.kafka.odyssey.DeleteResult: Creates an instance of a DeleteResult record class.
deleteStreamsTopology(ObjectIdentifier) - Method in interface io.confluent.rm.kafka.v1.RmStreamsTopologyClient: Deletes the StreamsTopology resource for a streams group.
deleteStreamsTopology(ObjectIdentifier) - Method in class io.confluent.rm.kafka.v1.RmStreamsTopologyClientImpl
deleteTopic(ObjectIdentifier) - Method in interface io.confluent.rm.kafka.v1.RmTopicClient: Deletes a topic from the resource manager.
deleteTopic(ObjectIdentifier) - Method in class io.confluent.rm.kafka.v1.RmTopicClientImpl
DESCRIBE_CONFIGS - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementRequestTypeMetrics.RequestType
DescribeConfigsOdysseyResult - Record Class in io.confluent.kafka.odyssey: Combined result of the DescribeConfigs Odyssey flow: the standard Kafka config response enriched with per-topic association fetch results.
DescribeConfigsOdysseyResult(DescribeConfigsResponseData, Map) - Constructor for record class io.confluent.kafka.odyssey.DescribeConfigsOdysseyResult: Creates an instance of a DescribeConfigsOdysseyResult record class.
Design - Section in interface io.confluent.kafka.odyssey.LsrcLookupService
DisassociateInfo - Record Class in io.confluent.kafka.odyssey: Disassociation request for a single topic.
DisassociateInfo(String, String, String, Set) - Constructor for record class io.confluent.kafka.odyssey.DisassociateInfo: Creates an instance of a DisassociateInfo record class.

E

empty() - Static method in record class io.confluent.kafka.odyssey.ParsedAssociations: Creates an empty ParsedAssociations with no key or value.
endpoint() - Method in record class io.confluent.kafka.odyssey.LsrcLookupResult: Returns the value of the endpoint record component.
equals(Object) - Method in record class io.confluent.kafka.odyssey.AssociationConfig: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.AssociationResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.auth.TokenRequestContext: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.ClassifyResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.DeleteResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.DescribeConfigsOdysseyResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.DisassociateInfo: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.KafkaResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.LsrcLookupResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.OdysseyManager.LargeAssociationPayloads: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.OdysseyRequestContext: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.OdysseyRequestManager.TokenAcquisitionResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.OdysseyResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.ParsedAssociations: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.TopicAssociationInfo: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.TopicClassification: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.ValidationContext: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.ValidationResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.rm.api.RmConfig: Indicates whether some other object is "equal to" this one.
errorCode() - Method in record class io.confluent.kafka.odyssey.OdysseyResult: Returns the value of the errorCode record component.
errorHandler(Consumer) - Method in interface io.confluent.rm.api.RmWatcher
errorMessage() - Method in record class io.confluent.kafka.odyssey.OdysseyRequestManager.TokenAcquisitionResult: Returns the value of the errorMessage record component.
errorMessage() - Method in record class io.confluent.kafka.odyssey.OdysseyResult: Returns the value of the errorMessage record component.
errorMessage() - Method in record class io.confluent.kafka.odyssey.ValidationContext: Returns the value of the errorMessage record component.
eventHandler(Consumer) - Method in interface io.confluent.rm.api.RmWatcher
ExternalSchemaUpdater - Interface in io.confluent.kafka.odyssey: Sets the external-schema type to MAYBE for the named topics, before their Schema Registry associations are created.
extractAssociations(Optional, Optional) - Static method in class io.confluent.kafka.odyssey.AssociationConfigParser: Parses the payloads a request supplied for the two association configs.
extractAssociations(CreateTopicsRequestData.CreatableTopic) - Static method in class io.confluent.kafka.odyssey.AssociationConfigParser: Extracts association configurations from a topic.
extractedAssociations() - Method in record class io.confluent.kafka.odyssey.ClassifyResult: Returns the value of the extractedAssociations record component.
extractedAssociations() - Method in record class io.confluent.kafka.odyssey.ValidationContext
extractedAssociations() - Method in record class io.confluent.kafka.odyssey.ValidationResult

F

FAILED_TO_PARSE_RESPONSE - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ErrorMessages
failure(int, short, String) - Static method in record class io.confluent.kafka.odyssey.OdysseyResult: Creates a failure result.
FAILURE - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.Outcome
FETCH - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.Stage
fetchAssociations(List, String, SchemaRegistryClient) - Method in interface io.confluent.kafka.odyssey.OdysseyRequestManager: Fetches existing schema associations (without their schemas) for the given topics from Schema Registry.
filterOdysseyConfigsFromTopics(CreateTopicsRequestData.CreatableTopicCollection) - Static method in class io.confluent.kafka.odyssey.AssociationConfigParser: Filters out Odyssey association configs from CreatableTopicCollection in-place.
filterOutOdysseyConfigs(Map) - Static method in class io.confluent.kafka.odyssey.AssociationConfigParser: Filters out Odyssey association configs from a config map.

G

GENERIC_UNEXPECTED_ERROR - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ErrorMessages
get(ObjectIdentifier) - Method in interface io.confluent.rm.api.RmClient
get(RmConfig, Supplier) - Method in interface io.confluent.rm.api.RmClientFactoryProvider
getClient(String, Optional, Map) - Method in interface io.confluent.kafka.odyssey.OdysseyRequestManager: Gets a SchemaRegistryClient for the given URL with HTTP headers and (for cloud) LSRC id.
getErrorType() - Method in exception class io.confluent.kafka.odyssey.auth.TokenPlatformException: Returns the error type for handling decisions.
getGroupConfig(ObjectIdentifier) - Method in interface io.confluent.rm.kafka.v1.RmGroupConfigClient: Retrieves the GroupConfig resource for an Group.
getGroupConfig(ObjectIdentifier) - Method in class io.confluent.rm.kafka.v1.RmGroupConfigClientImpl
getGrpcStatusCode() - Method in exception class io.confluent.kafka.odyssey.auth.TokenPlatformException: Returns the gRPC status code if available.
getHealthProbe(ObjectIdentifier) - Method in interface io.confluent.rm.kafka.v1.RmHealthProbeClient: Retrieves a HealthProbe resource from the resource manager.
getHealthProbe(ObjectIdentifier) - Method in class io.confluent.rm.kafka.v1.RmHealthProbeClientImpl
getLatest(InternalSwitchoverPair) - Method in class io.confluent.rm.kafka.v1.RmIspStatusReporter
getLatest(T) - Method in interface io.confluent.rm.kafka.v1.RmStatusReporter: Re-reads the resource from RM by its identity (name + scopes), returning the currently persisted copy with the latest resourceVersion.
getLifecycle() - Method in class io.confluent.kafka.odyssey.AssociationPayload
getMaterializedTable(ObjectIdentifier) - Method in interface io.confluent.rm.sql.v1.RmMaterializedTableClient: Retrieves a MaterializedTable resource from the resource manager.
getMaterializedTable(ObjectIdentifier) - Method in class io.confluent.rm.sql.v1.RmMaterializedTableClientImpl
getMetadata() - Method in class io.confluent.kafka.odyssey.AssociationPayload
getNormalize() - Method in class io.confluent.kafka.odyssey.AssociationPayload
getReferences() - Method in class io.confluent.kafka.odyssey.AssociationPayload
getRuleSet() - Method in class io.confluent.kafka.odyssey.AssociationPayload
getSchema() - Method in class io.confluent.kafka.odyssey.AssociationPayload
getSchemaRegistryEndpoint(String) - Method in interface io.confluent.kafka.odyssey.LsrcLookupService: Get the Schema Registry endpoint and LSRC id for a given Logical Kafka Cluster.
getSchemaTagsToAdd() - Method in class io.confluent.kafka.odyssey.AssociationPayload
getSchemaTagsToRemove() - Method in class io.confluent.kafka.odyssey.AssociationPayload
getSchemaType() - Method in class io.confluent.kafka.odyssey.AssociationPayload
getStreamsTopology(ObjectIdentifier) - Method in interface io.confluent.rm.kafka.v1.RmStreamsTopologyClient: Retrieves the StreamsTopology resource for a streams group.
getStreamsTopology(ObjectIdentifier) - Method in class io.confluent.rm.kafka.v1.RmStreamsTopologyClientImpl
getSubject() - Method in class io.confluent.kafka.odyssey.AssociationPayload
getTopic(ObjectIdentifier) - Method in interface io.confluent.rm.kafka.v1.RmTopicClient: Retrieves a topic from the resource manager.
getTopic(ObjectIdentifier) - Method in class io.confluent.rm.kafka.v1.RmTopicClientImpl
getTopicId(String) - Method in interface io.confluent.kafka.odyssey.TopicIdLookup: Look up the topic ID for a given topic name.
GroupConfigWatch() - Method in interface io.confluent.rm.kafka.v1.RmGroupConfigClient: Creates a watcher to monitor changes to GroupConfig resources.
GroupConfigWatch() - Method in class io.confluent.rm.kafka.v1.RmGroupConfigClientImpl

H

handleCreateTopicsWithOdyssey(CreateTopicsRequest, BiFunction, KafkaPrincipal) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager: Handles CreateTopics requests with Odyssey integration for K1.
handleCreateTopicsWithOdyssey(CreateTopicsRequest, BiFunction, KafkaPrincipal) - Method in interface io.confluent.kafka.odyssey.OdysseyManager: Handles CreateTopics requests with Odyssey integration for K1.
handleDeleteTopicsWithOdyssey(Map, Set, KafkaPrincipal) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager
handleDeleteTopicsWithOdyssey(Map, Set, KafkaPrincipal) - Method in interface io.confluent.kafka.odyssey.OdysseyManager: Handles DeleteTopics requests with Odyssey integration for K1.
handleDescribeConfigsWithOdyssey(DescribeConfigsResponseData, List, KafkaPrincipal, ConfluentAssociationFetchMode, boolean) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager: Handles DescribeConfigs requests with Odyssey integration for K1.
handleDescribeConfigsWithOdyssey(DescribeConfigsResponseData, List, KafkaPrincipal, ConfluentAssociationFetchMode, boolean) - Method in interface io.confluent.kafka.odyssey.OdysseyReadManager: Handles DescribeConfigs requests with Odyssey integration for K1.
handleIncrementalAlterConfigsWithOdyssey(Map, Map, KafkaPrincipal, boolean, ControllerConfigUpdater, Consumer, ExternalSchemaUpdater) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager
handleIncrementalAlterConfigsWithOdyssey(Map, Map, KafkaPrincipal, boolean, ControllerConfigUpdater, Consumer, ExternalSchemaUpdater) - Method in interface io.confluent.kafka.odyssey.OdysseyManager: Handles IncrementalAlterConfigs requests with Odyssey integration for K1.
hasAssociationConfigs(CreateTopicsRequestData.CreatableTopic) - Static method in class io.confluent.kafka.odyssey.AssociationConfigParser: Checks whether the topic carries an association in either place one can arrive: as an inline topic config, or as a tagged bytes field once the payload exceeds the inline string limit.
hasAssociations() - Method in record class io.confluent.kafka.odyssey.OdysseyResult: Returns true if this result contains fetched association data (key or value).
hasAssociations() - Method in record class io.confluent.kafka.odyssey.ParsedAssociations: Returns true if at least one association is present.
hashCode() - Method in record class io.confluent.kafka.odyssey.AssociationConfig: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.AssociationResult: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.auth.TokenRequestContext: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.ClassifyResult: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.DeleteResult: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.DescribeConfigsOdysseyResult: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.DisassociateInfo: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.KafkaResult: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.LsrcLookupResult: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.OdysseyManager.LargeAssociationPayloads: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.OdysseyRequestContext: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.OdysseyRequestManager.TokenAcquisitionResult: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.OdysseyResult: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.ParsedAssociations: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.TopicAssociationInfo: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.TopicClassification: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.ValidationContext: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.ValidationResult: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.rm.api.RmConfig: Returns a hash code value for this object.
hasOdysseyTopics() - Method in record class io.confluent.kafka.odyssey.ClassifyResult
healthProbeWatch() - Method in interface io.confluent.rm.kafka.v1.RmHealthProbeClient: Creates a watcher for monitoring HealthProbe changes in the resource manager.
healthProbeWatch() - Method in class io.confluent.rm.kafka.v1.RmHealthProbeClientImpl

I

id() - Method in record class io.confluent.kafka.odyssey.DeleteResult: Returns the value of the id record component.
Implementations: - Section in interface io.confluent.kafka.odyssey.OdysseyRequestManager
INCREMENTAL_ALTER_CONFIGS - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementRequestTypeMetrics.RequestType
initializationStrategy(RmWatcher.InitializationStrategy) - Method in interface io.confluent.rm.api.RmWatcher
INVALID_207_RESPONSE - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ErrorMessages
INVALID_ASSOCIATION_CONFIG - Enum constant in enum class io.confluent.kafka.odyssey.OdysseyConstants.ErrorCodes
InvalidLkcIdException(String) - Constructor for exception class io.confluent.kafka.odyssey.LsrcLookupException.InvalidLkcIdException
io.confluent.kafka.odyssey - package io.confluent.kafka.odyssey
io.confluent.kafka.odyssey.auth - package io.confluent.kafka.odyssey.auth
io.confluent.rm.api - package io.confluent.rm.api
io.confluent.rm.clusterlink.v1 - package io.confluent.rm.clusterlink.v1
io.confluent.rm.kafka.v1 - package io.confluent.rm.kafka.v1
io.confluent.rm.sql.v1 - package io.confluent.rm.sql.v1
isConfiguration() - Method in exception class io.confluent.kafka.odyssey.auth.TokenPlatformException: Returns whether this error is a configuration issue.
isEmpty() - Method in record class io.confluent.kafka.odyssey.ParsedAssociations: Returns true if neither key nor value association is present.
isIdempotent() - Method in record class io.confluent.kafka.odyssey.OdysseyResult: Returns the value of the isIdempotent record component.
isNotConfigured() - Method in record class io.confluent.kafka.odyssey.OdysseyRequestManager.TokenAcquisitionResult: Returns the value of the isNotConfigured record component.
isPermanent() - Method in exception class io.confluent.kafka.odyssey.auth.TokenPlatformException: Returns whether this error is permanent and will not succeed on retry.
isPermanent() - Method in record class io.confluent.kafka.odyssey.OdysseyRequestManager.TokenAcquisitionResult: Returns the value of the isPermanent record component.
isSuccess() - Method in record class io.confluent.kafka.odyssey.OdysseyRequestManager.TokenAcquisitionResult
isSuccess() - Method in record class io.confluent.kafka.odyssey.OdysseyResult: Returns the value of the isSuccess record component.
issueTokenAsync(TokenRequestContext, Executor) - Method in interface io.confluent.kafka.odyssey.auth.TokenPlatformClient: Issues a Logical Access Token (LAT) for the specified context asynchronously.
isTransient() - Method in exception class io.confluent.kafka.odyssey.auth.TokenPlatformException: Returns whether this error is transient and may succeed on retry.
isValidateOnly() - Method in record class io.confluent.kafka.odyssey.KafkaResult
isValidateOnly() - Method in record class io.confluent.kafka.odyssey.OdysseyRequestContext

J

JMX_DOMAIN_SCHEMA_MANAGEMENT - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.Metrics

K

KafkaClusterCrnBuilder - Class in io.confluent.kafka.odyssey.auth: Utility for building Kafka Logical Cluster CRNs.
kafkaErrorCode() - Method in record class io.confluent.kafka.odyssey.OdysseyResult: Returns the value of the kafkaErrorCode record component.
kafkaResponse() - Method in record class io.confluent.kafka.odyssey.AssociationResult
kafkaResponse() - Method in record class io.confluent.kafka.odyssey.KafkaResult: Returns the value of the kafkaResponse record component.
kafkaResult() - Method in record class io.confluent.kafka.odyssey.DescribeConfigsOdysseyResult: Returns the value of the kafkaResult record component.
KafkaResult - Record Class in io.confluent.kafka.odyssey
KafkaResult(ValidationResult, CreateTopicsRequestData, CreateTopicsResponseData, List, List) - Constructor for record class io.confluent.kafka.odyssey.KafkaResult: Creates an instance of a KafkaResult record class.
key() - Method in record class io.confluent.kafka.odyssey.OdysseyManager.LargeAssociationPayloads: Returns the value of the key record component.
key() - Method in record class io.confluent.kafka.odyssey.ParsedAssociations: Returns the value of the key record component.
KEY - Enum constant in enum class io.confluent.kafka.odyssey.AssociationType
KEY_ASSOCIATION_CONFIG - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ConfigKeys
KEY_ASSOCIATION_DOC - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ConfigKeys
keyAssociation() - Method in record class io.confluent.kafka.odyssey.OdysseyResult: Returns the value of the keyAssociation record component.

L

labelSelector(Map) - Method in interface io.confluent.rm.api.RmWatcher
LargeAssociationPayloads(Optional, Optional) - Constructor for record class io.confluent.kafka.odyssey.OdysseyManager.LargeAssociationPayloads: Creates an instance of a LargeAssociationPayloads record class.
lifecycle() - Method in record class io.confluent.kafka.odyssey.AssociationConfig: Returns the value of the lifecycle record component.
LIFECYCLE_STRONG - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.Defaults: Strong lifecycle for associations
LIFECYCLE_WEAK - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.Defaults: Default lifecycle for associations when not specified
list(Class, List, String) - Method in interface io.confluent.rm.api.RmClient
listClusterLinkLogicalKafkaClustersForAllEnvironments(String, String, int) - Method in class io.confluent.rm.clusterlink.v1.ClusterlinkApi: List ClusterLink LogicalKafkaCluster resources for all environments within an organization.
listClusterLinkSitesForAllEnvironments(String, String, int) - Method in class io.confluent.rm.clusterlink.v1.ClusterlinkApi: List ClusterLink Site resources for all environments within an organization.
listHealthProbes(List, String) - Method in interface io.confluent.rm.kafka.v1.RmHealthProbeClient: Lists a single page of HealthProbe resources in the given scope.
listHealthProbes(List, String) - Method in class io.confluent.rm.kafka.v1.RmHealthProbeClientImpl
LoadSnapshot() - Constructor for class io.confluent.rm.api.RmWatcher.LoadSnapshot
lsrcId() - Method in record class io.confluent.kafka.odyssey.ClassifyResult
lsrcId() - Method in record class io.confluent.kafka.odyssey.LsrcLookupResult: Returns the value of the lsrcId record component.
lsrcId() - Method in record class io.confluent.kafka.odyssey.OdysseyRequestContext: Returns the value of the lsrcId record component.
LsrcLookupException - Exception Class in io.confluent.kafka.odyssey: Base exception for LSRC lookup failures.
LsrcLookupException(String) - Constructor for exception class io.confluent.kafka.odyssey.LsrcLookupException
LsrcLookupException(String, Throwable) - Constructor for exception class io.confluent.kafka.odyssey.LsrcLookupException
LsrcLookupException.InvalidLkcIdException - Exception Class in io.confluent.kafka.odyssey: Invalid LKC ID provided (null or empty).
LsrcLookupException.LsrcLookupServiceException - Exception Class in io.confluent.kafka.odyssey: RRI client error (network, timeout, service unavailable).
LsrcLookupException.LsrcMappingNotFoundException - Exception Class in io.confluent.kafka.odyssey: No LKC→LSRC mapping found in Resource Manager or missing endpoint in mapping.
LsrcLookupResult - Record Class in io.confluent.kafka.odyssey: Result of a Schema Registry endpoint lookup for a Logical Kafka Cluster.
LsrcLookupResult(String, Optional) - Constructor for record class io.confluent.kafka.odyssey.LsrcLookupResult: Creates an instance of a LsrcLookupResult record class.
LsrcLookupService - Interface in io.confluent.kafka.odyssey: Service for looking up Schema Registry endpoints from Resource Manager's RRI (Resource Relation Index).
LsrcLookupServiceException(String, Throwable) - Constructor for exception class io.confluent.kafka.odyssey.LsrcLookupException.LsrcLookupServiceException
LsrcMappingNotFoundException(String) - Constructor for exception class io.confluent.kafka.odyssey.LsrcLookupException.LsrcMappingNotFoundException

M

MAX_QUEUE_SIZE - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.Defaults: Max queue size for bounded work queue
MAX_THREADS - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.Defaults: Max threads for Odyssey request thread pool
maxRetries() - Method in record class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig: Returns the value of the maxRetries record component.
MISSING_REQUIRED_CONFIG - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ErrorMessages

N

name() - Method in record class io.confluent.kafka.odyssey.DeleteResult: Returns the value of the name record component.
namespace() - Method in record class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig: Returns the value of the namespace record component.
namespace() - Method in record class io.confluent.kafka.odyssey.ClassifyResult
namespace() - Method in record class io.confluent.kafka.odyssey.DisassociateInfo: Returns the value of the namespace record component.
namespace() - Method in record class io.confluent.kafka.odyssey.KafkaResult
namespace() - Method in record class io.confluent.kafka.odyssey.OdysseyRequestContext: Returns the value of the namespace record component.
namespace() - Method in record class io.confluent.kafka.odyssey.TopicAssociationInfo: Returns the value of the namespace record component.
namespace() - Method in record class io.confluent.kafka.odyssey.ValidationContext
namespace() - Method in record class io.confluent.kafka.odyssey.ValidationResult
networkError(String, Throwable) - Static method in exception class io.confluent.kafka.odyssey.auth.TokenPlatformException: Creates an exception for network/connectivity issues.
newDefaultRmClientFactory() - Static method in interface io.confluent.rm.api.RmClientFactoryProvider
normalize() - Method in record class io.confluent.kafka.odyssey.AssociationConfig: Returns the value of the normalize record component.
notConfigured() - Static method in record class io.confluent.kafka.odyssey.OdysseyRequestManager.TokenAcquisitionResult
notifyDeleteTopicsResult(Set, Map) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager
notifyDeleteTopicsResult(Set, Map) - Method in interface io.confluent.kafka.odyssey.OdysseyManager: Reports per-topic results from the post-Odyssey Kafka delete so SR-committed-but-Kafka-failed topics — the orphan-event boundary — can be observed.
notReady(ClassifyResult, String) - Static method in record class io.confluent.kafka.odyssey.ValidationContext

O

ODYSSEY_ERROR - Enum constant in enum class io.confluent.kafka.odyssey.OdysseyConstants.ErrorCodes
ODYSSEY_OVERLOADED - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ErrorMessages
ODYSSEY_TIMEOUT - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ErrorMessages
OdysseyConstants - Class in io.confluent.kafka.odyssey: Constants used throughout the Odyssey integration module.
OdysseyConstants.ConfigKeys - Class in io.confluent.kafka.odyssey: Configuration keys for topic association configs.
OdysseyConstants.Defaults - Class in io.confluent.kafka.odyssey: Default values for Odyssey configurations.
OdysseyConstants.ErrorCodes - Enum Class in io.confluent.kafka.odyssey: Odyssey-owned error codes surfaced as the schemaErrorCode on results; OdysseyConstants.ErrorCodes.code() is the integer value.
OdysseyConstants.ErrorMessages - Class in io.confluent.kafka.odyssey: Error messages for common scenarios.
OdysseyConstants.Metrics - Class in io.confluent.kafka.odyssey: Metrics constants for Schema Management JMX surfaces.
OdysseyIntegrationManager - Class in io.confluent.kafka.odyssey: Manages the integration between Kafka topic creation and Odyssey (Schema Registry) associations for K1.
OdysseyIntegrationManager(OdysseyRequestManager, TopicIdLookup, String, LogContext, Time, LsrcLookupService, BrokerType, String) - Constructor for class io.confluent.kafka.odyssey.OdysseyIntegrationManager: Test-only constructor.
OdysseyIntegrationManager.Builder - Class in io.confluent.kafka.odyssey: Builder for OdysseyIntegrationManager.
OdysseyManager - Interface in io.confluent.kafka.odyssey: Full Odyssey integration interface used by the controller server.
OdysseyManager.LargeAssociationPayloads - Record Class in io.confluent.kafka.odyssey: A resource's association payloads that the request carried as tagged bytes rather than as inline config values, because they exceed the limit the protocol can encode in a string field.
OdysseyReadManager - Interface in io.confluent.kafka.odyssey: Read-only Odyssey integration operations used by the broker server.
OdysseyRequestContext - Record Class in io.confluent.kafka.odyssey
OdysseyRequestContext(CreateTopicsRequestData, String, String, Optional, BiFunction) - Constructor for record class io.confluent.kafka.odyssey.OdysseyRequestContext: Creates an instance of a OdysseyRequestContext record class.
OdysseyRequestManager - Interface in io.confluent.kafka.odyssey: Interface for managing asynchronous requests to Odyssey (Schema Registry).
OdysseyRequestManager.RequestOp - Enum Class in io.confluent.kafka.odyssey
OdysseyRequestManager.TokenAcquisitionResult - Record Class in io.confluent.kafka.odyssey: Result of token acquisition from Token Platform.
OdysseyResult - Record Class in io.confluent.kafka.odyssey: Result of any Odyssey operation (validation, association creation, fetch, etc.).
OdysseyResult(boolean, int, short, Optional, boolean, Optional, Optional) - Constructor for record class io.confluent.kafka.odyssey.OdysseyResult: Creates an instance of a OdysseyResult record class.
orgResourceId() - Method in record class io.confluent.kafka.odyssey.auth.TokenRequestContext: Returns the value of the orgResourceId record component.
ORPHAN_REMEDIATION - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ErrorMessages

P

ParsedAssociations - Record Class in io.confluent.kafka.odyssey: Holds parsed association configurations for key and value.
ParsedAssociations(Optional, Optional) - Constructor for record class io.confluent.kafka.odyssey.ParsedAssociations: Creates an instance of a ParsedAssociations record class.
parseFailures() - Method in record class io.confluent.kafka.odyssey.ClassifyResult: Returns the value of the parseFailures record component.
passedValidation() - Method in record class io.confluent.kafka.odyssey.ValidationResult: Returns the value of the passedValidation record component.
PERMANENT - Enum constant in enum class io.confluent.kafka.odyssey.auth.TokenPlatformException.ErrorType: Permanent errors that will not succeed on retry.
permanentError(String) - Static method in record class io.confluent.kafka.odyssey.OdysseyRequestManager.TokenAcquisitionResult
podLabel() - Method in record class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig: Returns the value of the podLabel record component.
principalResourceId() - Method in record class io.confluent.kafka.odyssey.auth.TokenRequestContext: Returns the value of the principalResourceId record component.

R

readClusterLinkLogicalKafkaCluster(String, String, String) - Method in class io.confluent.rm.clusterlink.v1.ClusterlinkApi: Read a ClusterLink LogicalKafkaCluster resource.
readClusterLinkSite(String, String, String) - Method in class io.confluent.rm.clusterlink.v1.ClusterlinkApi: Read a ClusterLink Site resource.
ready(ClassifyResult, SchemaRegistryClient) - Static method in record class io.confluent.kafka.odyssey.ValidationContext
recordCall(SchemaManagementDependencyMetrics.Target, SchemaManagementDependencyMetrics.Stage, SchemaManagementDependencyMetrics.Outcome) - Method in class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics
recordEndToEndLatency(SchemaManagementRequestTypeMetrics.RequestType, long) - Method in class io.confluent.kafka.odyssey.SchemaManagementRequestTypeMetrics
recordError(SchemaManagementDependencyMetrics.Target, SchemaManagementDependencyMetrics.Stage, SchemaManagementDependencyMetrics.ErrorClass) - Method in class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics
recordError(SchemaManagementDependencyMetrics.Target, SchemaManagementDependencyMetrics.Stage, SchemaManagementDependencyMetrics.ErrorClass, long) - Method in class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics
recordFailedRequest(SchemaManagementRequestTypeMetrics.RequestType) - Method in class io.confluent.kafka.odyssey.SchemaManagementRequestTypeMetrics: Marks a request failed iff the merged response carries ≥1 topic with a Schema Management-attributable error — validation, association, LSRC lookup, token acquisition, or pipeline-level handling.
recordLatency(SchemaManagementDependencyMetrics.Target, SchemaManagementDependencyMetrics.Stage, long) - Method in class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics
recordOrphanedAssociationDeleted() - Method in class io.confluent.kafka.odyssey.SchemaManagementRequestTypeMetrics: Fires when SR association removal succeeded but the subsequent Kafka delete failed.
recordOrphanedAssociationDeleted(long) - Method in class io.confluent.kafka.odyssey.SchemaManagementRequestTypeMetrics
recordOrphanedTopicCreated() - Method in class io.confluent.kafka.odyssey.SchemaManagementRequestTypeMetrics: Fires when Kafka created the topic but the subsequent SR association call failed.
recordOutcome(SchemaManagementDependencyMetrics.Target, SchemaManagementDependencyMetrics.Stage, SchemaManagementDependencyMetrics.Outcome, long) - Method in class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics: Convenience for the common case: record the call's outcome and its latency together.
recordPartialAlterConfigsApply(long) - Method in class io.confluent.kafka.odyssey.SchemaManagementRequestTypeMetrics: Fires when IncrementalAlterConfigs committed a resource's non-association config changes to the controller but the subsequent Schema Registry association update failed — a partial apply the failed per-resource response does not reveal (there is no rollback).
recordRequest(SchemaManagementRequestTypeMetrics.RequestType) - Method in class io.confluent.kafka.odyssey.SchemaManagementRequestTypeMetrics
recordTopicClassified(SchemaManagementRequestTypeMetrics.RequestType, boolean) - Method in class io.confluent.kafka.odyssey.SchemaManagementRequestTypeMetrics: Marks one topic encountered by requestType.
recordTopicClassified(SchemaManagementRequestTypeMetrics.RequestType, boolean, long) - Method in class io.confluent.kafka.odyssey.SchemaManagementRequestTypeMetrics
recordTopicsPerRequest(SchemaManagementRequestTypeMetrics.RequestType, int) - Method in class io.confluent.kafka.odyssey.SchemaManagementRequestTypeMetrics
regionalResourceManagerClientSchedulerThreads() - Method in record class io.confluent.rm.api.RmConfig: Returns the value of the regionalResourceManagerClientSchedulerThreads record component.
regionalResourceManagerEndpointUrl() - Method in record class io.confluent.rm.api.RmConfig: Returns the value of the regionalResourceManagerEndpointUrl record component.
regionalResourceManagerGrpcEndpointUrl() - Method in record class io.confluent.rm.api.RmConfig: Returns the value of the regionalResourceManagerGrpcEndpointUrl record component.
regionalResourceManagerSpiffeIds() - Method in record class io.confluent.rm.api.RmConfig: Returns the value of the regionalResourceManagerSpiffeIds record component.
removeDeletedTopicFinalizer(DeletedTopic, String) - Method in interface io.confluent.rm.kafka.v1.RmTopicClient: Remove a finalizer from a DeletedTopic.
removeDeletedTopicFinalizer(DeletedTopic, String) - Method in class io.confluent.rm.kafka.v1.RmTopicClientImpl
removeFinalizer(Topic, String) - Method in interface io.confluent.rm.kafka.v1.RmTopicClient: Removes a finalizer from a topic, allowing it to be deleted when all finalizers are removed.
removeFinalizer(Topic, String) - Method in class io.confluent.rm.kafka.v1.RmTopicClientImpl
reportStatus(InternalSwitchoverPair, Condition) - Method in class io.confluent.rm.kafka.v1.RmIspStatusReporter
reportStatus(T, Condition) - Method in interface io.confluent.rm.kafka.v1.RmStatusReporter: Sets the status condition for the resource.
request() - Method in record class io.confluent.kafka.odyssey.AssociationResult
request() - Method in record class io.confluent.kafka.odyssey.ClassifyResult: Returns the value of the request record component.
request() - Method in record class io.confluent.kafka.odyssey.KafkaResult
request() - Method in record class io.confluent.kafka.odyssey.OdysseyRequestContext: Returns the value of the request record component.
request() - Method in record class io.confluent.kafka.odyssey.ValidationContext
request() - Method in record class io.confluent.kafka.odyssey.ValidationResult
REQUEST_TIMEOUT_MS - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.Defaults: Request timeout in milliseconds
requestTimeoutMs() - Method in record class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig: Returns the value of the requestTimeoutMs record component.
RESOLVE - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.Stage
RESOURCE_TYPE_TOPIC - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.Defaults: Resource type for Kafka topics
result() - Method in record class io.confluent.kafka.odyssey.DeleteResult: Returns the value of the result record component.
retryTopics() - Method in record class io.confluent.kafka.odyssey.KafkaResult: Returns the value of the retryTopics record component.
RM - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.Target
RmClient - Interface in io.confluent.rm.api: Simple shim interface to make unit testing easier
RmClientFactory - Interface in io.confluent.rm.api
RmClientFactoryProvider - Interface in io.confluent.rm.api
rmClientSpireEnable() - Method in record class io.confluent.rm.api.RmConfig: Returns the value of the rmClientSpireEnable record component.
RmConfig - Record Class in io.confluent.rm.api
RmConfig(String, String, Integer, String, String, Boolean, String, String) - Constructor for record class io.confluent.rm.api.RmConfig: Creates an instance of a RmConfig record class.
RmGroupConfigClient - Interface in io.confluent.rm.kafka.v1: Client interface for managing group dynamic configurations in the resource manager.
RmGroupConfigClientImpl - Class in io.confluent.rm.kafka.v1: Implementation of RmGroupConfigClient using RmClient.
RmGroupConfigClientImpl(RmClient) - Constructor for class io.confluent.rm.kafka.v1.RmGroupConfigClientImpl
RmHealthProbeClient - Interface in io.confluent.rm.kafka.v1: Client interface for managing HealthProbe resources in the resource manager.
RmHealthProbeClientImpl - Class in io.confluent.rm.kafka.v1: Implementation of RmHealthProbeClient using RmClient.
RmHealthProbeClientImpl(RmClient) - Constructor for class io.confluent.rm.kafka.v1.RmHealthProbeClientImpl
RmIspStatusReporter - Class in io.confluent.rm.kafka.v1: Status reporter for managing InternalSwitchoverPair resource lifecycle.
RmIspStatusReporter(RmClient) - Constructor for class io.confluent.rm.kafka.v1.RmIspStatusReporter: Creates a new RmIspStatusReporter.
RmMaterializedTableClient - Interface in io.confluent.rm.sql.v1
RmMaterializedTableClientImpl - Class in io.confluent.rm.sql.v1: Implementation of RmMaterializedTableClient using RmClient.
RmMaterializedTableClientImpl(RmClient) - Constructor for class io.confluent.rm.sql.v1.RmMaterializedTableClientImpl
RmRawClientFactory - Interface in io.confluent.rm.api: Factory for building raw Resource Manager Client instances without the RmClient wrapper.
RmStatusReporter<T> - Interface in io.confluent.rm.kafka.v1: Helper for managing RM resource status, finalizers, and observed generation.
RmStreamsTopologyClient - Interface in io.confluent.rm.kafka.v1: Client interface for managing StreamsTopology resources in the resource manager.
RmStreamsTopologyClientImpl - Class in io.confluent.rm.kafka.v1: Implementation of RmStreamsTopologyClient using RmClient.
RmStreamsTopologyClientImpl(RmClient) - Constructor for class io.confluent.rm.kafka.v1.RmStreamsTopologyClientImpl
RmSubscription - Interface in io.confluent.rm.api: Simple shim interface for Watcher.Subscription
RmTopicClient - Interface in io.confluent.rm.kafka.v1: Client interface for managing topics and deleted topics in the resource manager.
RmTopicClientImpl - Class in io.confluent.rm.kafka.v1: Convenience wrapper around a Client.
RmTopicClientImpl(RmClient) - Constructor for class io.confluent.rm.kafka.v1.RmTopicClientImpl
RmWatcher<T> - Interface in io.confluent.rm.api: Shim interface for Watcher.
RmWatcher.ContinueFromEnd - Class in io.confluent.rm.api: Start a watch stream at its tail.
RmWatcher.ContinueWithToken - Class in io.confluent.rm.api: Continue a watch stream from a token.
RmWatcher.InitializationStrategy - Interface in io.confluent.rm.api: Strategy for how the watch stream is initialized
RmWatcher.LoadSnapshot - Class in io.confluent.rm.api: Start a watch stream with a full snapshot.

S

schema() - Method in record class io.confluent.kafka.odyssey.AssociationConfig: Returns the value of the schema record component.
SCHEMA_TYPE_AVRO - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.Defaults: Default schema type when not specified
SchemaManagementDependencyMetrics - Class in io.confluent.kafka.odyssey: Per-dependency drill-down metrics: CallsPerSec (Meter), LatencyMs (Histogram), ErrorsPerSec (Meter).
SchemaManagementDependencyMetrics(Set) - Constructor for class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics
SchemaManagementDependencyMetrics.ErrorClass - Enum Class in io.confluent.kafka.odyssey: Bounded classification of a dependency-call error, used as the error_class tag.
SchemaManagementDependencyMetrics.Outcome - Enum Class in io.confluent.kafka.odyssey
SchemaManagementDependencyMetrics.Stage - Enum Class in io.confluent.kafka.odyssey
SchemaManagementDependencyMetrics.Target - Enum Class in io.confluent.kafka.odyssey
SchemaManagementRequestTypeMetrics - Class in io.confluent.kafka.odyssey: Per-request-type SLO metrics for Schema Management.
SchemaManagementRequestTypeMetrics() - Constructor for class io.confluent.kafka.odyssey.SchemaManagementRequestTypeMetrics
SchemaManagementRequestTypeMetrics.RequestType - Enum Class in io.confluent.kafka.odyssey
schemaMetadata() - Method in record class io.confluent.kafka.odyssey.AssociationConfig: Returns the value of the schemaMetadata record component.
schemaReferences() - Method in record class io.confluent.kafka.odyssey.AssociationConfig: Returns the value of the schemaReferences record component.
schemaRegistryUrl() - Method in record class io.confluent.kafka.odyssey.ClassifyResult
schemaRegistryUrl() - Method in record class io.confluent.kafka.odyssey.OdysseyRequestContext: Returns the value of the schemaRegistryUrl record component.
schemaRuleSet() - Method in record class io.confluent.kafka.odyssey.AssociationConfig: Returns the value of the schemaRuleSet record component.
schemaTagsToAdd() - Method in record class io.confluent.kafka.odyssey.AssociationConfig: Returns the value of the schemaTagsToAdd record component.
schemaTagsToRemove() - Method in record class io.confluent.kafka.odyssey.AssociationConfig: Returns the value of the schemaTagsToRemove record component.
schemaType() - Method in record class io.confluent.kafka.odyssey.AssociationConfig: Returns the value of the schemaType record component.
SERVER_ERROR - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.ErrorClass
serverError() - Static method in record class io.confluent.kafka.odyssey.OdysseyResult
serviceAcct() - Method in record class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig: Returns the value of the serviceAcct record component.
setBrokerServiceAccountId(String) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager.Builder
setClusterId(String) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager.Builder
setConfigs(AbstractConfig) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager.Builder
setHasAssociationsLookup(Predicate) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager.Builder: Sets the per-topic "may this topic have schema associations?" predicate consulted by the DescribeConfigs and DeleteTopics flows.
setLifecycle(String) - Method in class io.confluent.kafka.odyssey.AssociationConfig.Builder
setLifecycle(String) - Method in class io.confluent.kafka.odyssey.AssociationPayload
setLogContext(LogContext) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager.Builder
setMetadata(Metadata) - Method in class io.confluent.kafka.odyssey.AssociationPayload
setNormalize(Boolean) - Method in class io.confluent.kafka.odyssey.AssociationConfig.Builder
setNormalize(Boolean) - Method in class io.confluent.kafka.odyssey.AssociationPayload
setObservedGeneration(InternalSwitchoverPair) - Method in class io.confluent.rm.kafka.v1.RmIspStatusReporter
setObservedGeneration(T) - Method in interface io.confluent.rm.kafka.v1.RmStatusReporter: Updates the observed generation in the status field to match spec.generation
setReferences(List) - Method in class io.confluent.kafka.odyssey.AssociationPayload
setRegionalResourceManagerSpiffeIds(String) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager.Builder
setRmClientSpireEnable(boolean) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager.Builder
setRmGrpcEndpoint(String) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager.Builder
setRmHttpEndpoint(String) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager.Builder
setRuleSet(RuleSet) - Method in class io.confluent.kafka.odyssey.AssociationPayload
setSchema(String) - Method in class io.confluent.kafka.odyssey.AssociationConfig.Builder
setSchema(String) - Method in class io.confluent.kafka.odyssey.AssociationPayload
setSchemaMetadata(Metadata) - Method in class io.confluent.kafka.odyssey.AssociationConfig.Builder
setSchemaReferences(List) - Method in class io.confluent.kafka.odyssey.AssociationConfig.Builder
setSchemaRuleSet(RuleSet) - Method in class io.confluent.kafka.odyssey.AssociationConfig.Builder
setSchemaTagsToAdd(List) - Method in class io.confluent.kafka.odyssey.AssociationConfig.Builder
setSchemaTagsToAdd(List) - Method in class io.confluent.kafka.odyssey.AssociationPayload
setSchemaTagsToRemove(List) - Method in class io.confluent.kafka.odyssey.AssociationConfig.Builder
setSchemaTagsToRemove(List) - Method in class io.confluent.kafka.odyssey.AssociationPayload
setSchemaType(String) - Method in class io.confluent.kafka.odyssey.AssociationConfig.Builder
setSchemaType(String) - Method in class io.confluent.kafka.odyssey.AssociationPayload
setSpireAgentUrl(String) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager.Builder
setSslFactorySupplier(Supplier) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager.Builder
setSubject(String) - Method in class io.confluent.kafka.odyssey.AssociationConfig.Builder
setSubject(String) - Method in class io.confluent.kafka.odyssey.AssociationPayload
setTime(Time) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager.Builder
setTokenPlatformEndpoint(String) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager.Builder
setTopicIdLookup(TopicIdLookup) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager.Builder
SPIRE_AGENT - Enum constant in enum class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig.AuthMode: Agent-mode mTLS: SVID fetched from SPIRE Workload API socket.
SPIRE_K8S_SECRET - Enum constant in enum class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig.AuthMode: K8s-secret-mode mTLS: SVID read from Kubernetes secret via K8s API.
spireAgentUrl() - Method in record class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig: Returns the value of the spireAgentUrl record component.
spireAgentUrl() - Method in record class io.confluent.rm.api.RmConfig: Returns the value of the spireAgentUrl record component.
SR - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.Target
srClient() - Method in record class io.confluent.kafka.odyssey.KafkaResult
srClient() - Method in record class io.confluent.kafka.odyssey.ValidationContext: Returns the value of the srClient record component.
srClient() - Method in record class io.confluent.kafka.odyssey.ValidationResult
srClientReady() - Method in record class io.confluent.kafka.odyssey.ValidationContext: Returns the value of the srClientReady record component.
subject() - Method in record class io.confluent.kafka.odyssey.AssociationConfig: Returns the value of the subject record component.
subscribe() - Method in interface io.confluent.rm.api.RmWatcher
subscriptionId(String) - Method in interface io.confluent.rm.api.RmWatcher
success() - Static method in record class io.confluent.kafka.odyssey.OdysseyResult: Creates a success result (mutation path — no association data).
success(boolean) - Static method in record class io.confluent.kafka.odyssey.OdysseyResult: Creates a success result with idempotent flag (mutation path).
success(String) - Static method in record class io.confluent.kafka.odyssey.OdysseyRequestManager.TokenAcquisitionResult
SUCCESS - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.Outcome
successfulTopics() - Method in record class io.confluent.kafka.odyssey.KafkaResult: Returns the value of the successfulTopics record component.
successWithAssociations(Optional, Optional) - Static method in record class io.confluent.kafka.odyssey.OdysseyResult: Creates a success result with fetched association data (read path — DescribeConfigs).

T

targetWorkloadType() - Method in record class io.confluent.kafka.odyssey.auth.TokenRequestContext: Returns the value of the targetWorkloadType record component.
THREAD_IDLE_TIMEOUT_SECONDS - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.Defaults: Thread idle timeout in seconds before core threads are terminated
Thread Safety: - Section in interface io.confluent.kafka.odyssey.TopicIdLookup
token() - Method in record class io.confluent.kafka.odyssey.OdysseyRequestManager.TokenAcquisitionResult: Returns the value of the token record component.
TOKEN - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.Stage
TokenAcquisitionResult(Optional, String, boolean, boolean) - Constructor for record class io.confluent.kafka.odyssey.OdysseyRequestManager.TokenAcquisitionResult: Creates an instance of a TokenAcquisitionResult record class.
TokenPlatformClient - Interface in io.confluent.kafka.odyssey.auth: Client interface for obtaining Logical Access Tokens (LAT) from the Token Platform service.
TokenPlatformClientConfig - Record Class in io.confluent.kafka.odyssey.auth: Immutable configuration for TokenPlatformClient.
TokenPlatformClientConfig(String, TokenPlatformClientConfig.AuthMode, String, String, String, String, int, int) - Constructor for record class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig: Compact constructor — null safety only.
TokenPlatformClientConfig.AuthMode - Enum Class in io.confluent.kafka.odyssey.auth: SPIRE authentication mode for the gRPC channel to Token Platform.
TokenPlatformException - Exception Class in io.confluent.kafka.odyssey.auth: Exception thrown when Token Platform operations fail.
TokenPlatformException(String, TokenPlatformException.ErrorType) - Constructor for exception class io.confluent.kafka.odyssey.auth.TokenPlatformException: Creates a new TokenPlatformException.
TokenPlatformException(String, Throwable, TokenPlatformException.ErrorType) - Constructor for exception class io.confluent.kafka.odyssey.auth.TokenPlatformException: Creates a new TokenPlatformException with a cause.
TokenPlatformException(String, Throwable, TokenPlatformException.ErrorType, String) - Constructor for exception class io.confluent.kafka.odyssey.auth.TokenPlatformException: Creates a new TokenPlatformException with gRPC status information.
TokenPlatformException.ErrorType - Enum Class in io.confluent.kafka.odyssey.auth: Categorizes the type of error for appropriate handling.
tokenPlatformUrl() - Method in record class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig: Returns the value of the tokenPlatformUrl record component.
TokenRequestContext - Record Class in io.confluent.kafka.odyssey.auth: Context required to issue a Logical Access Token from Token Platform.
TokenRequestContext(String, String, String, TargetPhysicalWorkloadType) - Constructor for record class io.confluent.kafka.odyssey.auth.TokenRequestContext: Creates an instance of a TokenRequestContext record class.
toList() - Method in record class io.confluent.kafka.odyssey.ParsedAssociations: Returns associations as a list for SR API compatibility.
TOPIC_ID_NOT_FOUND - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ErrorMessages
TopicAssociationInfo - Record Class in io.confluent.kafka.odyssey: Association information for a single topic.
TopicAssociationInfo(String, String, String, ParsedAssociations) - Constructor for record class io.confluent.kafka.odyssey.TopicAssociationInfo: Creates an instance of a TopicAssociationInfo record class.
TopicClassification - Record Class in io.confluent.kafka.odyssey
TopicClassification(List, List, Set) - Constructor for record class io.confluent.kafka.odyssey.TopicClassification: Creates an instance of a TopicClassification record class.
topicCreator() - Method in record class io.confluent.kafka.odyssey.OdysseyRequestContext: Returns the value of the topicCreator record component.
topicId() - Method in record class io.confluent.kafka.odyssey.DisassociateInfo: Returns the value of the topicId record component.
topicId() - Method in record class io.confluent.kafka.odyssey.TopicAssociationInfo: Returns the value of the topicId record component.
TopicIdLookup - Interface in io.confluent.kafka.odyssey: Functional interface for looking up topic IDs.
topicName() - Method in record class io.confluent.kafka.odyssey.DisassociateInfo: Returns the value of the topicName record component.
topicName() - Method in record class io.confluent.kafka.odyssey.TopicAssociationInfo: Returns the value of the topicName record component.
topicNamesWithoutOdysseyConfigs() - Method in record class io.confluent.kafka.odyssey.ClassifyResult
topicNamesWithoutOdysseyConfigs() - Method in record class io.confluent.kafka.odyssey.TopicClassification: Returns the value of the topicNamesWithoutOdysseyConfigs record component.
topicsWithAssociationConfigs() - Method in record class io.confluent.kafka.odyssey.KafkaResult: Returns the value of the topicsWithAssociationConfigs record component.
topicsWithOdysseyConfigs() - Method in record class io.confluent.kafka.odyssey.ClassifyResult
topicsWithOdysseyConfigs() - Method in record class io.confluent.kafka.odyssey.TopicClassification: Returns the value of the topicsWithOdysseyConfigs record component.
topicsWithOdysseyConfigs() - Method in record class io.confluent.kafka.odyssey.ValidationContext
topicsWithOdysseyConfigs() - Method in record class io.confluent.kafka.odyssey.ValidationResult
topicsWithoutOdysseyConfigs() - Method in record class io.confluent.kafka.odyssey.TopicClassification: Returns the value of the topicsWithoutOdysseyConfigs record component.
topicWatch() - Method in interface io.confluent.rm.kafka.v1.RmTopicClient: Creates a watcher for monitoring topic changes in the resource manager.
topicWatch() - Method in class io.confluent.rm.kafka.v1.RmTopicClientImpl
toString() - Method in record class io.confluent.kafka.odyssey.AssociationConfig: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.AssociationResult: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig: Returns a string representation of this record class.
toString() - Method in exception class io.confluent.kafka.odyssey.auth.TokenPlatformException
toString() - Method in record class io.confluent.kafka.odyssey.auth.TokenRequestContext: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.ClassifyResult: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.DeleteResult: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.DescribeConfigsOdysseyResult: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.DisassociateInfo: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.KafkaResult: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.LsrcLookupResult: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.OdysseyManager.LargeAssociationPayloads: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.OdysseyRequestContext: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.OdysseyRequestManager.TokenAcquisitionResult: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.OdysseyResult: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.ParsedAssociations: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.TopicAssociationInfo: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.TopicClassification: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.ValidationContext: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.ValidationResult: Returns a string representation of this record class.
toString() - Method in record class io.confluent.rm.api.RmConfig: Returns a string representation of this record class.
TP - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.Target
TRANSIENT - Enum constant in enum class io.confluent.kafka.odyssey.auth.TokenPlatformException.ErrorType: Transient errors that may succeed on retry.
transientError(String) - Static method in record class io.confluent.kafka.odyssey.OdysseyRequestManager.TokenAcquisitionResult
tryFromWireString(String) - Static method in enum class io.confluent.kafka.odyssey.AssociationType: Returns the matching enum value, or Optional.empty() if the input is not a recognized association type (including null).
types() - Method in record class io.confluent.kafka.odyssey.DisassociateInfo: Returns the value of the types record component.

U

UNAVAILABLE - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.ErrorClass
UNEXPECTED_ERROR - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ErrorMessages
update(T) - Method in interface io.confluent.rm.api.RmClient
UPDATE_ASSOC - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.Stage
updateAssociations(List, List, SchemaRegistryClient) - Method in interface io.confluent.kafka.odyssey.OdysseyRequestManager: Executes a mixed upsert+disassociate SR update (used by IncrementalAlterConfigs flow).
updateDynamicConfigs(GroupConfig, GroupDynamicConfigs) - Method in interface io.confluent.rm.kafka.v1.RmGroupConfigClient: Updates the Dynamic Configuration for existing Group resource.
updateDynamicConfigs(GroupConfig, GroupDynamicConfigs) - Method in class io.confluent.rm.kafka.v1.RmGroupConfigClientImpl
updateDynamicConfigs(Topic, DynamicConfigs) - Method in interface io.confluent.rm.kafka.v1.RmTopicClient: Updates the dynamic configuration settings for an existing topic.
updateDynamicConfigs(Topic, DynamicConfigs) - Method in class io.confluent.rm.kafka.v1.RmTopicClientImpl
updateMirrorTopic(Topic, MirrorTopicSpec, MirrorTopicStatus, List) - Method in interface io.confluent.rm.kafka.v1.RmTopicClient: Updates the mirror metadata for a topic.
updateMirrorTopic(Topic, MirrorTopicSpec, MirrorTopicStatus, List) - Method in class io.confluent.rm.kafka.v1.RmTopicClientImpl
updateStreamsTopology(StreamsTopology) - Method in interface io.confluent.rm.kafka.v1.RmStreamsTopologyClient: Updates an existing StreamsTopology resource.
updateStreamsTopology(StreamsTopology) - Method in class io.confluent.rm.kafka.v1.RmStreamsTopologyClientImpl
updateTopicPartitions(Topic, Partitions) - Method in interface io.confluent.rm.kafka.v1.RmTopicClient: Updates the partition configuration for an existing topic.
updateTopicPartitions(Topic, Partitions) - Method in class io.confluent.rm.kafka.v1.RmTopicClientImpl
UPSERT - Enum constant in enum class io.confluent.kafka.odyssey.OdysseyRequestManager.RequestOp

V

validate(Map, String, SchemaRegistryClient) - Method in interface io.confluent.kafka.odyssey.OdysseyRequestManager: Validates a batch against SR (dry-run=true).
VALIDATE - Enum constant in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.Stage
validated() - Method in record class io.confluent.kafka.odyssey.KafkaResult: Returns the value of the validated record component.
validateMixedBatch(List, List, String, SchemaRegistryClient) - Method in interface io.confluent.kafka.odyssey.OdysseyRequestManager: Validates a mixed upsert+disassociate batch against SR (dry-run=true).
validationContext() - Method in record class io.confluent.kafka.odyssey.ValidationResult: Returns the value of the validationContext record component.
ValidationContext - Record Class in io.confluent.kafka.odyssey: Context for the validation phase, containing classified topics and SR client.
ValidationContext(ClassifyResult, SchemaRegistryClient, boolean, String) - Constructor for record class io.confluent.kafka.odyssey.ValidationContext: Creates an instance of a ValidationContext record class.
validationFailures() - Method in record class io.confluent.kafka.odyssey.AssociationResult
validationFailures() - Method in record class io.confluent.kafka.odyssey.KafkaResult
validationFailures() - Method in record class io.confluent.kafka.odyssey.ValidationResult: Returns the value of the validationFailures record component.
ValidationResult - Record Class in io.confluent.kafka.odyssey
ValidationResult(ValidationContext, Set, Map) - Constructor for record class io.confluent.kafka.odyssey.ValidationResult: Creates an instance of a ValidationResult record class.
value() - Method in record class io.confluent.kafka.odyssey.OdysseyManager.LargeAssociationPayloads: Returns the value of the value record component.
value() - Method in record class io.confluent.kafka.odyssey.ParsedAssociations: Returns the value of the value record component.
VALUE - Enum constant in enum class io.confluent.kafka.odyssey.AssociationType
VALUE_ASSOCIATION_CONFIG - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ConfigKeys
VALUE_ASSOCIATION_DOC - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ConfigKeys
valueAssociation() - Method in record class io.confluent.kafka.odyssey.OdysseyResult: Returns the value of the valueAssociation record component.
valueOf(String) - Static method in enum class io.confluent.kafka.odyssey.AssociationType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig.AuthMode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.odyssey.auth.TokenPlatformException.ErrorType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.odyssey.OdysseyConstants.ErrorCodes: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.odyssey.OdysseyRequestManager.RequestOp: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.ErrorClass: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.Outcome: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.Stage: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.Target: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.odyssey.SchemaManagementRequestTypeMetrics.RequestType: Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.confluent.kafka.odyssey.AssociationType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig.AuthMode: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.kafka.odyssey.auth.TokenPlatformException.ErrorType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.kafka.odyssey.OdysseyConstants.ErrorCodes: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.kafka.odyssey.OdysseyRequestManager.RequestOp: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.ErrorClass: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.Outcome: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.Stage: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.kafka.odyssey.SchemaManagementDependencyMetrics.Target: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.kafka.odyssey.SchemaManagementRequestTypeMetrics.RequestType: Returns an array containing the constants of this enum class, in the order they are declared.

W

watch(Class) - Method in interface io.confluent.rm.api.RmClient
wireString() - Method in enum class io.confluent.kafka.odyssey.AssociationType: The lowercase string used in Schema Registry's association data structures (e.g., the associationType field of AssociationInfo / AssociationCreateOp on the SR REST API).

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