Index (ce-odyssey 8.3.0-ce API)

A B C D E F G H I K L M N O P Q 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
ASSOCIATION_CREATION_FAILED - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ErrorCodes: Association creation failed after topic was created (partial success)
AssociationConfig - Record Class in io.confluent.kafka.odyssey: Configuration for a schema association (key or value).
AssociationConfig(String, String, String, Optional, Optional, Optional, Optional, Optional, Boolean) - Constructor for record class io.confluent.kafka.odyssey.AssociationConfig: Creates an instance of a AssociationConfig record class.
AssociationConfigParser - Class in io.confluent.kafka.odyssey: Parser for Odyssey association configurations
associationList() - Method in record class io.confluent.kafka.odyssey.TopicAssociationInfo
AssociationPayload - Class in io.confluent.kafka.odyssey
AssociationPayload() - Constructor for class io.confluent.kafka.odyssey.AssociationPayload
AssociationResult(OdysseyFlowRecords.KafkaResult) - Constructor for record class io.confluent.kafka.odyssey.OdysseyFlowRecords.AssociationResult: Creates an instance of a AssociationResult record class.
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.
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.

B

brokerServiceAccountId() - Method in record class io.confluent.rm.api.RmConfig: Returns the value of the brokerServiceAccountId record component.
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
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.OdysseyFlowRecords.ClassifyResult: Returns the value of the classification record component.
classification() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ValidationResult
classified() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ValidationResult: Returns the value of the classified record component.
ClassifyResult(OdysseyFlowRecords.OdysseyRequestContext, OdysseyFlowRecords.TopicClassification, Map) - Constructor for record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ClassifyResult: Creates an instance of a ClassifyResult record class.
close() - Method in class io.confluent.kafka.odyssey.auth.NoAuthTokenPlatformClient
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.DefaultOdysseyRequestManager
close() - Method in interface io.confluent.kafka.odyssey.OdysseyRequestManager: Gracefully shuts down the manager, cleaning up resources.
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
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
create(String, String) - Method in class io.confluent.kafka.odyssey.auth.DefaultTokenPlatformClientFactory
create(String, String) - Static method in record class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig: Creates a configuration with default timeout and retry settings.
create(String, String) - Method in interface io.confluent.kafka.odyssey.auth.TokenPlatformClientFactory: Creates a TokenPlatformClient based on the provided configuration.
create(T) - Method in interface io.confluent.rm.api.RmClient
createAssociations(List, boolean, SchemaRegistryClient) - Method in class io.confluent.kafka.odyssey.DefaultOdysseyRequestManager
createAssociations(List, boolean, SchemaRegistryClient) - Method in interface io.confluent.kafka.odyssey.OdysseyRequestManager: Creates associations with Odyssey.
createClient(String) - Method in class io.confluent.kafka.odyssey.DefaultOdysseyRequestManager
createClient(String) - Method in interface io.confluent.kafka.odyssey.OdysseyRequestManager: Creates a SchemaRegistryClient for the given URL.
created() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.AssociationResult: Returns the value of the created record component.

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
DefaultLsrcLookupService - Class in io.confluent.kafka.odyssey: Implementation of LsrcLookupService using Resource Manager's RRI (Resource Relation Index).
DefaultLsrcLookupService(Client) - Constructor for class io.confluent.kafka.odyssey.DefaultLsrcLookupService: LsrcLookupService from a Resource Manager client.
DefaultLsrcLookupService(RRIClient) - Constructor for class io.confluent.kafka.odyssey.DefaultLsrcLookupService: LsrcLookupService using an existing RRIClient.
DefaultOdysseyRequestManager - Class in io.confluent.kafka.odyssey
DefaultOdysseyRequestManager() - Constructor for class io.confluent.kafka.odyssey.DefaultOdysseyRequestManager: Creates a DefaultOdysseyRequestManager with default settings.
DefaultOdysseyRequestManager(int, int, int) - Constructor for class io.confluent.kafka.odyssey.DefaultOdysseyRequestManager: Creates a DefaultOdysseyRequestManager with custom thread pool settings.
DefaultOdysseyRequestManager(int, int, int, Map) - Constructor for class io.confluent.kafka.odyssey.DefaultOdysseyRequestManager: Creates a DefaultOdysseyRequestManager with custom settings and configuration.
DefaultTokenPlatformClientFactory - Class in io.confluent.kafka.odyssey.auth: Default implementation of TokenPlatformClientFactory.
DefaultTokenPlatformClientFactory() - Constructor for class io.confluent.kafka.odyssey.auth.DefaultTokenPlatformClientFactory
delete(ObjectIdentifier) - Method in interface io.confluent.rm.api.RmClient
Design - Section in interface io.confluent.kafka.odyssey.LsrcLookupService

E

empty() - Static method in record class io.confluent.kafka.odyssey.ParsedAssociations: Creates an empty ParsedAssociations with no key or value.
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.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.OdysseyFlowRecords.AssociationResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ClassifyResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.KafkaResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.OdysseyRequestContext: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.TopicClassification: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ValidationResult: 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.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.OdysseyResult: Returns the value of the errorMessage record component.
eventHandler(Consumer) - Method in interface io.confluent.rm.api.RmWatcher
extractAssociations(CreateTopicsRequestData.CreatableTopicConfigCollection) - Static method in class io.confluent.kafka.odyssey.AssociationConfigParser: Extracts association configurations from topic configs.
extractedAssociations() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ClassifyResult: Returns the value of the extractedAssociations record component.
extractNamespace(KafkaPrincipal) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager: Extracts namespace from request principal (K1-specific).

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.
Features: - Section in class io.confluent.kafka.odyssey.DefaultLsrcLookupService
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

get(ObjectIdentifier) - Method in interface io.confluent.rm.api.RmClient
get(RmConfig, Supplier) - Method in interface io.confluent.rm.api.RmClientFactoryProvider
getDefault() - Static method in interface io.confluent.kafka.odyssey.auth.TokenPlatformClientFactory: Returns the default factory implementation.
getErrorType() - Method in exception class io.confluent.kafka.odyssey.auth.TokenPlatformException: Returns the error type for handling decisions.
getGrpcStatusCode() - Method in exception class io.confluent.kafka.odyssey.auth.TokenPlatformException: Returns the gRPC status code if available.
getLifecycle() - Method in class io.confluent.kafka.odyssey.AssociationPayload
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 class io.confluent.kafka.odyssey.DefaultLsrcLookupService
getSchemaRegistryEndpoint(String) - Method in interface io.confluent.kafka.odyssey.LsrcLookupService: Get the Schema Registry public endpoint for a given Logical Kafka Cluster.
getSchemaType() - Method in class io.confluent.kafka.odyssey.AssociationPayload
getSubject() - Method in class io.confluent.kafka.odyssey.AssociationPayload
getTopicId(String) - Method in interface io.confluent.kafka.odyssey.TopicIdLookup: Look up the topic ID for a given topic name.

H

handleCreateTopicsWithOdyssey(CreateTopicsRequest, String, Function) - Method in class io.confluent.kafka.odyssey.OdysseyIntegrationManager: Handles CreateTopics requests with Odyssey integration for K1.
hasAssociationConfigs(CreateTopicsRequestData.CreatableTopicConfigCollection) - Static method in class io.confluent.kafka.odyssey.AssociationConfigParser: Checks if the topic configs contain any Odyssey association configs.
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.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.OdysseyFlowRecords.AssociationResult: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ClassifyResult: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.KafkaResult: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.OdysseyRequestContext: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.TopicClassification: Returns a hash code value for this object.
hashCode() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ValidationResult: 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.rm.api.RmConfig: Returns a hash code value for this object.

I

Implementations: - Section in interface io.confluent.kafka.odyssey.OdysseyRequestManager
initializationStrategy(RmWatcher.InitializationStrategy) - Method in interface io.confluent.rm.api.RmWatcher
INVALID_207_RESPONSE - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ErrorMessages
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
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.
isPermanent() - Method in exception class io.confluent.kafka.odyssey.auth.TokenPlatformException: Returns whether this error is permanent and will not succeed on retry.
isSuccess() - Method in record class io.confluent.kafka.odyssey.OdysseyResult: Returns the value of the isSuccess record component.
issueTokenAsync(TokenRequestContext, Executor) - Method in class io.confluent.kafka.odyssey.auth.NoAuthTokenPlatformClient
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.OdysseyFlowRecords.KafkaResult
isValidateOnly() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.OdysseyRequestContext

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.OdysseyFlowRecords.AssociationResult
kafkaResponse() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.KafkaResult: Returns the value of the kafkaResponse record component.
KafkaResult(OdysseyFlowRecords.ValidationResult, CreateTopicsRequestData, CreateTopicsResponseData, List, List) - Constructor for record class io.confluent.kafka.odyssey.OdysseyFlowRecords.KafkaResult: Creates an instance of a KafkaResult record class.
kafkaTopicCreator() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.OdysseyRequestContext: Returns the value of the kafkaTopicCreator record component.
key() - Method in record class io.confluent.kafka.odyssey.ParsedAssociations: Returns the value of the key record component.
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

L

labelSelector(String) - Method in interface io.confluent.rm.api.RmWatcher
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
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.
LoadSnapshot() - Constructor for class io.confluent.rm.api.RmWatcher.LoadSnapshot
LOCAL_DEV_SENTINEL - Static variable in interface io.confluent.kafka.odyssey.auth.TokenPlatformClientFactory: Sentinel prefix for local development mode endpoints.
LsrcLookupService - Interface in io.confluent.kafka.odyssey: Service for looking up Schema Registry endpoints from Resource Manager's RRI (Resource Relation Index).

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

namespace() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ClassifyResult
namespace() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.KafkaResult
namespace() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.OdysseyRequestContext: Returns the value of the namespace record component.
namespace() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ValidationResult
namespace() - Method in record class io.confluent.kafka.odyssey.TopicAssociationInfo: Returns the value of the namespace record component.
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
NoAuthTokenPlatformClient - Class in io.confluent.kafka.odyssey.auth: Token Platform client for local development that bypasses authentication.
NoAuthTokenPlatformClient() - Constructor for class io.confluent.kafka.odyssey.auth.NoAuthTokenPlatformClient
normalize() - Method in record class io.confluent.kafka.odyssey.AssociationConfig: Returns the value of the normalize record component.

O

ODYSSEY_ERROR - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ErrorCodes: Generic Odyssey/Schema Registry error code
ODYSSEY_OVERLOADED - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ErrorMessages
ODYSSEY_SERVICE_ERROR - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ErrorMessages
ODYSSEY_SR_UNAVAILABLE - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ErrorCodes: Schema Registry endpoint unavailable
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 - Class in io.confluent.kafka.odyssey: Error codes used in Odyssey integration.
OdysseyConstants.ErrorMessages - Class in io.confluent.kafka.odyssey: Error messages for common scenarios.
OdysseyFlowRecords - Class in io.confluent.kafka.odyssey
OdysseyFlowRecords() - Constructor for class io.confluent.kafka.odyssey.OdysseyFlowRecords
OdysseyFlowRecords.AssociationResult - Record Class in io.confluent.kafka.odyssey
OdysseyFlowRecords.ClassifyResult - Record Class in io.confluent.kafka.odyssey
OdysseyFlowRecords.KafkaResult - Record Class in io.confluent.kafka.odyssey
OdysseyFlowRecords.OdysseyRequestContext - Record Class in io.confluent.kafka.odyssey
OdysseyFlowRecords.TopicClassification - Record Class in io.confluent.kafka.odyssey
OdysseyFlowRecords.ValidationResult - Record Class in io.confluent.kafka.odyssey
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, LsrcLookupService) - Constructor for class io.confluent.kafka.odyssey.OdysseyIntegrationManager: Creates a new OdysseyIntegrationManager with dynamic SR endpoint resolution.
OdysseyRequestContext(CreateTopicsRequestData, String, SchemaRegistryClient, Function) - Constructor for record class io.confluent.kafka.odyssey.OdysseyFlowRecords.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).
OdysseyResult - Record Class in io.confluent.kafka.odyssey: Result of any Odyssey operation (validation, association creation, etc.).
OdysseyResult(boolean, int, short, Optional, boolean) - 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.

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.
passedValidation() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.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.
principalResourceId() - Method in record class io.confluent.kafka.odyssey.auth.TokenRequestContext: Returns the value of the principalResourceId record component.

Q

QUEUE_WARNING_INTERVAL_MS - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.Defaults: Minimum time between queue warnings (milliseconds)
QUEUE_WARNING_THRESHOLD - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.Defaults: Queue warning threshold as percentage

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.
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.
request() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.AssociationResult
request() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ClassifyResult: Returns the value of the request record component.
request() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.KafkaResult
request() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.OdysseyRequestContext: Returns the value of the request record component.
request() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.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.
RESOURCE_TYPE_TOPIC - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.Defaults: Resource type for Kafka topics
retryTopics() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.KafkaResult: Returns the value of the retryTopics record component.
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) - Constructor for record class io.confluent.rm.api.RmConfig: Creates an instance of a RmConfig record class.
RmRawClientFactory - Interface in io.confluent.rm.api: Factory for building raw Resource Manager Client instances without the RmClient wrapper.
RmSubscription - Interface in io.confluent.rm.api: Simple shim interface for Watcher.Subscription
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
SCHEMA_VALIDATION_ERROR - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ErrorCodes: Schema validation failed (Schema Registry error)
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.
schemaRuleSet() - Method in record class io.confluent.kafka.odyssey.AssociationConfig: Returns the value of the schemaRuleSet record component.
schemaType() - Method in record class io.confluent.kafka.odyssey.AssociationConfig: Returns the value of the schemaType record component.
setLifecycle(String) - Method in class io.confluent.kafka.odyssey.AssociationPayload
setMetadata(Metadata) - Method in class io.confluent.kafka.odyssey.AssociationPayload
setNormalize(Boolean) - Method in class io.confluent.kafka.odyssey.AssociationPayload
setReferences(List) - Method in class io.confluent.kafka.odyssey.AssociationPayload
setRuleSet(RuleSet) - Method in class io.confluent.kafka.odyssey.AssociationPayload
setSchema(String) - Method in class io.confluent.kafka.odyssey.AssociationPayload
setSchemaType(String) - Method in class io.confluent.kafka.odyssey.AssociationPayload
setSubject(String) - Method in class io.confluent.kafka.odyssey.AssociationPayload
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.
srClient() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ClassifyResult
srClient() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.KafkaResult
srClient() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.OdysseyRequestContext: Returns the value of the srClient record component.
srClient() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ValidationResult
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.
success(boolean) - Static method in record class io.confluent.kafka.odyssey.OdysseyResult: Creates a success result with idempotent flag.
successfulTopics() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.KafkaResult: Returns the value of the successfulTopics record component.

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 class io.confluent.kafka.odyssey.DefaultLsrcLookupService
Thread Safety: - Section in interface io.confluent.kafka.odyssey.TopicIdLookup
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, String, int, int) - Constructor for record class io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig: Compact constructor with validation.
TokenPlatformClientFactory - Interface in io.confluent.kafka.odyssey.auth: Factory interface for creating TokenPlatformClient instances.
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.
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(List, List, Set) - Constructor for record class io.confluent.kafka.odyssey.OdysseyFlowRecords.TopicClassification: Creates an instance of a TopicClassification record class.
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.TopicAssociationInfo: Returns the value of the topicName record component.
topicNamesWithoutOdysseyConfigs() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ClassifyResult
topicNamesWithoutOdysseyConfigs() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.TopicClassification: Returns the value of the topicNamesWithoutOdysseyConfigs record component.
topicsWithAssociationConfigs() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.KafkaResult: Returns the value of the topicsWithAssociationConfigs record component.
topicsWithOdysseyConfigs() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ClassifyResult
topicsWithOdysseyConfigs() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.TopicClassification: Returns the value of the topicsWithOdysseyConfigs record component.
topicsWithoutOdysseyConfigs() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.TopicClassification: Returns the value of the topicsWithoutOdysseyConfigs record component.
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.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.OdysseyFlowRecords.AssociationResult: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ClassifyResult: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.KafkaResult: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.OdysseyRequestContext: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.TopicClassification: Returns a string representation of this record class.
toString() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ValidationResult: 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.rm.api.RmConfig: Returns a string representation of this record class.
TRANSIENT - Enum constant in enum class io.confluent.kafka.odyssey.auth.TokenPlatformException.ErrorType: Transient errors that may succeed on retry.
TYPE_KEY - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ConfigKeys
TYPE_VALUE - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ConfigKeys

U

UNEXPECTED_ERROR - Static variable in class io.confluent.kafka.odyssey.OdysseyConstants.ErrorMessages
update(T) - Method in interface io.confluent.rm.api.RmClient

V

validate(Map, String, SchemaRegistryClient) - Method in class io.confluent.kafka.odyssey.DefaultOdysseyRequestManager
validate(Map, String, SchemaRegistryClient) - Method in interface io.confluent.kafka.odyssey.OdysseyRequestManager
validated() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.KafkaResult: Returns the value of the validated record component.
validationFailures() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.AssociationResult
validationFailures() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.KafkaResult
validationFailures() - Method in record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ValidationResult: Returns the value of the validationFailures record component.
ValidationResult(OdysseyFlowRecords.ClassifyResult, Set, Map) - Constructor for record class io.confluent.kafka.odyssey.OdysseyFlowRecords.ValidationResult: Creates an instance of a ValidationResult record class.
value() - Method in record class io.confluent.kafka.odyssey.ParsedAssociations: Returns the value of the value record component.
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
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.
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.

W

watch(Class) - Method in interface io.confluent.rm.api.RmClient

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