All Classes and Interfaces
Class
Description
Configuration for a schema association (key or value).
Parser for Odyssey association configurations
Clusterlink API client using the RM Java client with protobuf-based models.
Implementation of LsrcLookupService using Resource Manager's RRI (Resource Relation Index).
Default implementation of
TokenPlatformClientFactory.Utility for building Kafka Logical Cluster CRNs.
Service for looking up Schema Registry endpoints from Resource Manager's RRI (Resource Relation Index).
Token Platform client for local development that bypasses authentication.
Constants used throughout the Odyssey integration module.
Configuration keys for topic association configs.
Default values for Odyssey configurations.
Error codes used in Odyssey integration.
Error messages for common scenarios.
Manages the integration between Kafka topic creation and Odyssey (Schema Registry) associations for K1.
Interface for managing asynchronous requests to Odyssey (Schema Registry).
Result of any Odyssey operation (validation, association creation, etc.).
Holds parsed association configurations for key and value.
Simple shim interface to make unit testing easier
Factory for building raw Resource Manager
Client instances without
the RmClient wrapper.Simple shim interface for
Watcher.SubscriptionShim interface for
Watcher.Start a watch stream at its tail.
Continue a watch stream from a token.
Strategy for how the watch stream is initialized
Start a watch stream with a full snapshot.
Client interface for obtaining Logical Access Tokens (LAT) from the Token Platform service.
Immutable configuration for
TokenPlatformClient.Factory interface for creating
TokenPlatformClient instances.Exception thrown when Token Platform operations fail.
Categorizes the type of error for appropriate handling.
Context required to issue a Logical Access Token from Token Platform.
Association information for a single topic.
Functional interface for looking up topic IDs.