Package io.confluent.kafka.odyssey
package io.confluent.kafka.odyssey
-
ClassDescriptionConfiguration for a schema association (key or value).Parser for Odyssey association configurationsJackson-deserialisable representation of the JSON value supplied by the user for
confluent.key.association/confluent.value.associationconfig keys.Which side of a record an association applies to: key or value.Result of topic classification before token acquisition.Callback that applies stripped config changes via the Kafka controller.Per-topic outcome of an Odyssey delete request.Combined result of the DescribeConfigs Odyssey flow: the standard Kafka config response enriched with per-topic association fetch results.Disassociation request for a single topic.Sets the external-schema type to MAYBE for the named topics, before their Schema Registry associations are created.Base exception for LSRC lookup failures.Invalid LKC ID provided (null or empty).RRI client error (network, timeout, service unavailable).No LKCāLSRC mapping found in Resource Manager or missing endpoint in mapping.Result of a Schema Registry endpoint lookup for a Logical Kafka Cluster.Service for looking up Schema Registry endpoints from Resource Manager's RRI (Resource Relation Index).Constants used throughout the Odyssey integration module.Configuration keys for topic association configs.Default values for Odyssey configurations.Odyssey-owned error codes surfaced as theschemaErrorCodeon results;OdysseyConstants.ErrorCodes.code()is the integer value.Error messages for common scenarios.Metrics constants for Schema Management JMX surfaces.Manages the integration between Kafka topic creation and Odyssey (Schema Registry) associations for K1.Builder for OdysseyIntegrationManager.Full Odyssey integration interface used by the controller server.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.Read-only Odyssey integration operations used by the broker server.Interface for managing asynchronous requests to Odyssey (Schema Registry).Result of token acquisition from Token Platform.Result of any Odyssey operation (validation, association creation, fetch, etc.).Holds parsed association configurations for key and value.Per-dependency drill-down metrics:CallsPerSec(Meter),LatencyMs(Histogram),ErrorsPerSec(Meter).Bounded classification of a dependency-call error, used as theerror_classtag.Per-request-type SLO metrics for Schema Management.Association information for a single topic.Functional interface for looking up topic IDs.Context for the validation phase, containing classified topics and SR client.