Class KafkaClusterCrnBuilder

java.lang.Object
io.confluent.kafka.odyssey.auth.KafkaClusterCrnBuilder

public final class KafkaClusterCrnBuilder extends Object
Utility for building Kafka Logical Cluster CRNs.

This builder is specific to Odyssey/Kafka use cases. Other services (Schema Registry, Connect, etc.) should implement their own CRN builders.

The CRN format for Kafka Logical Clusters is: crn://confluent.cloud/organization=<org>/environment=<env>/cloud-cluster=<lkc>/kafka=<lkc>

  • Method Details

    • buildAuthenticatedPrincipalCrn

      public static String buildAuthenticatedPrincipalCrn(String organizationId, String environmentId, String clusterId)
      Builds a Kafka Logical Cluster CRN for use as the authenticated principal.
      Parameters:
      organizationId - the organization resource ID (e.g., "org-xxxxx")
      environmentId - the environment ID (e.g., "env-xxxxx")
      clusterId - the logical cluster ID (e.g., "lkc-xxxxx")
      Returns:
      the formatted CRN