Interface LsrcLookupService

All Known Implementing Classes:
DefaultLsrcLookupService
public interface LsrcLookupService
Service for looking up Schema Registry endpoints from Resource Manager's RRI (Resource Relation Index).

Uses the LKCToLSRC resource to map Logical Kafka Cluster IDs to their corresponding Schema Registry Cluster endpoints.

Design

  • Async API: All methods return CompletableFuture to avoid blocking controller threads
  • Graceful degradation: Returns empty Optional when mapping not found

  • Method Details

    • getSchemaRegistryEndpoint

      CompletableFuture<Optional<String>> getSchemaRegistryEndpoint(String lkcId)
      Get the Schema Registry public endpoint for a given Logical Kafka Cluster.

      This method queries the Resource Manager's RRI LKCToLSRC resource to find the mapping from LKC to LSRC and extracts the public endpoint URL.

      Parameters:
      lkcId - the Logical Kafka Cluster ID (e.g., "lkc-abc123"), must not be null
      Returns:
      a CompletableFuture containing Optional with the Schema Registry public endpoint URL, or empty Optional if no mapping exists. Never returns null.