Viewing docs for Confluent v2.61.0
published on Saturday, Mar 21, 2026 by Pulumi
published on Saturday, Mar 21, 2026 by Pulumi
Viewing docs for Confluent v2.61.0
published on Saturday, Mar 21, 2026 by Pulumi
published on Saturday, Mar 21, 2026 by Pulumi
confluent_subject_compatibility_level describes a Subject Config data source.
Example Usage
Option #1: Manage multiple Schema Registry clusters in the same Pulumi Stack
import * as pulumi from "@pulumi/pulumi";
import * as confluent from "@pulumi/confluent";
const example = confluent.index.SubjectCompatibilityLevel({
schemaRegistryCluster: [{
id: essentials.id,
}],
restEndpoint: essentials.restEndpoint,
subjectName: "proto-purchase-value",
credentials: [{
key: "<Schema Registry API Key for confluent_schema_registry_region.essentials>",
secret: "<Schema Registry API Secret for confluent_schema_registry_region.essentials>",
}],
});
export const compatibilityLevel = example.compatibilityLevel;
import pulumi
import pulumi_confluent as confluent
example = confluent.index.subject_compatibility_level(schema_registry_cluster=[{
"id": essentials["id"],
}],
rest_endpoint=essentials["restEndpoint"],
subject_name="proto-purchase-value",
credentials=[{
"key": "<Schema Registry API Key for confluent_schema_registry_region.essentials>",
"secret": "<Schema Registry API Secret for confluent_schema_registry_region.essentials>",
}])
pulumi.export("compatibilityLevel", example["compatibilityLevel"])
package main
import (
"github.com/pulumi/pulumi-confluent/sdk/go/confluent"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
example, err := confluent.SubjectCompatibilityLevel(ctx, map[string]interface{}{
"schemaRegistryCluster": []map[string]interface{}{
map[string]interface{}{
"id": essentials.Id,
},
},
"restEndpoint": essentials.RestEndpoint,
"subjectName": "proto-purchase-value",
"credentials": []map[string]interface{}{
map[string]interface{}{
"key": "<Schema Registry API Key for confluent_schema_registry_region.essentials>",
"secret": "<Schema Registry API Secret for confluent_schema_registry_region.essentials>",
},
},
}, nil)
if err != nil {
return err
}
ctx.Export("compatibilityLevel", example.CompatibilityLevel)
return nil
})
}
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Confluent = Pulumi.Confluent;
return await Deployment.RunAsync(() =>
{
var example = Confluent.Index.SubjectCompatibilityLevel.Invoke(new()
{
SchemaRegistryCluster = new[]
{
{
{ "id", essentials.Id },
},
},
RestEndpoint = essentials.RestEndpoint,
SubjectName = "proto-purchase-value",
Credentials = new[]
{
{
{ "key", "<Schema Registry API Key for confluent_schema_registry_region.essentials>" },
{ "secret", "<Schema Registry API Secret for confluent_schema_registry_region.essentials>" },
},
},
});
return new Dictionary<string, object?>
{
["compatibilityLevel"] = example.CompatibilityLevel,
};
});
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.confluent.ConfluentFunctions;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
final var example = ConfluentFunctions.SubjectCompatibilityLevel(Map.ofEntries(
Map.entry("schemaRegistryCluster", List.of(Map.of("id", essentials.id()))),
Map.entry("restEndpoint", essentials.restEndpoint()),
Map.entry("subjectName", "proto-purchase-value"),
Map.entry("credentials", List.of(Map.ofEntries(
Map.entry("key", "<Schema Registry API Key for confluent_schema_registry_region.essentials>"),
Map.entry("secret", "<Schema Registry API Secret for confluent_schema_registry_region.essentials>")
)))
));
ctx.export("compatibilityLevel", example.compatibilityLevel());
}
}
variables:
example:
fn::invoke:
function: confluent:SubjectCompatibilityLevel
arguments:
schemaRegistryCluster:
- id: ${essentials.id}
restEndpoint: ${essentials.restEndpoint}
subjectName: proto-purchase-value
credentials:
- key: <Schema Registry API Key for confluent_schema_registry_region.essentials>
secret: <Schema Registry API Secret for confluent_schema_registry_region.essentials>
outputs:
compatibilityLevel: ${example.compatibilityLevel}
Option #2: Manage a single Schema Registry cluster in the same Pulumi Stack
import * as pulumi from "@pulumi/pulumi";
import * as confluent from "@pulumi/confluent";
const example = confluent.index.SubjectCompatibilityLevel({
subjectName: "proto-purchase-value",
});
export const compatibilityLevel = example.compatibilityLevel;
import pulumi
import pulumi_confluent as confluent
example = confluent.index.subject_compatibility_level(subject_name="proto-purchase-value")
pulumi.export("compatibilityLevel", example["compatibilityLevel"])
package main
import (
"github.com/pulumi/pulumi-confluent/sdk/go/confluent"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
example, err := confluent.SubjectCompatibilityLevel(ctx, map[string]interface{}{
"subjectName": "proto-purchase-value",
}, nil)
if err != nil {
return err
}
ctx.Export("compatibilityLevel", example.CompatibilityLevel)
return nil
})
}
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Confluent = Pulumi.Confluent;
return await Deployment.RunAsync(() =>
{
var example = Confluent.Index.SubjectCompatibilityLevel.Invoke(new()
{
SubjectName = "proto-purchase-value",
});
return new Dictionary<string, object?>
{
["compatibilityLevel"] = example.CompatibilityLevel,
};
});
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.confluent.ConfluentFunctions;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
final var example = ConfluentFunctions.SubjectCompatibilityLevel(Map.of("subjectName", "proto-purchase-value"));
ctx.export("compatibilityLevel", example.compatibilityLevel());
}
}
variables:
example:
fn::invoke:
function: confluent:SubjectCompatibilityLevel
arguments:
subjectName: proto-purchase-value
outputs:
compatibilityLevel: ${example.compatibilityLevel}
Using getSubjectConfig
Two invocation forms are available. The direct form accepts plain arguments and either blocks until the result value is available, or returns a Promise-wrapped result. The output form accepts Input-wrapped arguments and returns an Output-wrapped result.
function getSubjectConfig(args: GetSubjectConfigArgs, opts?: InvokeOptions): Promise<GetSubjectConfigResult>
function getSubjectConfigOutput(args: GetSubjectConfigOutputArgs, opts?: InvokeOptions): Output<GetSubjectConfigResult>def get_subject_config(credentials: Optional[GetSubjectConfigCredentials] = None,
rest_endpoint: Optional[str] = None,
schema_registry_cluster: Optional[GetSubjectConfigSchemaRegistryCluster] = None,
subject_name: Optional[str] = None,
opts: Optional[InvokeOptions] = None) -> GetSubjectConfigResult
def get_subject_config_output(credentials: Optional[pulumi.Input[GetSubjectConfigCredentialsArgs]] = None,
rest_endpoint: Optional[pulumi.Input[str]] = None,
schema_registry_cluster: Optional[pulumi.Input[GetSubjectConfigSchemaRegistryClusterArgs]] = None,
subject_name: Optional[pulumi.Input[str]] = None,
opts: Optional[InvokeOptions] = None) -> Output[GetSubjectConfigResult]func LookupSubjectConfig(ctx *Context, args *LookupSubjectConfigArgs, opts ...InvokeOption) (*LookupSubjectConfigResult, error)
func LookupSubjectConfigOutput(ctx *Context, args *LookupSubjectConfigOutputArgs, opts ...InvokeOption) LookupSubjectConfigResultOutput> Note: This function is named LookupSubjectConfig in the Go SDK.
public static class GetSubjectConfig
{
public static Task<GetSubjectConfigResult> InvokeAsync(GetSubjectConfigArgs args, InvokeOptions? opts = null)
public static Output<GetSubjectConfigResult> Invoke(GetSubjectConfigInvokeArgs args, InvokeOptions? opts = null)
}public static CompletableFuture<GetSubjectConfigResult> getSubjectConfig(GetSubjectConfigArgs args, InvokeOptions options)
public static Output<GetSubjectConfigResult> getSubjectConfig(GetSubjectConfigArgs args, InvokeOptions options)
fn::invoke:
function: confluentcloud:index/getSubjectConfig:getSubjectConfig
arguments:
# arguments dictionaryThe following arguments are supported:
- Subject
Name string - The name of the subject (in other words, the namespace), representing the subject under which the schema will be registered, for example,
test-subject. - Credentials
Pulumi.
Confluent Cloud. Inputs. Get Subject Config Credentials - Rest
Endpoint string - The REST endpoint of the Schema Registry cluster, for example,
https://psrc-00000.us-central1.gcp.confluent.cloud:443). - Schema
Registry Pulumi.Cluster Confluent Cloud. Inputs. Get Subject Config Schema Registry Cluster
- Subject
Name string - The name of the subject (in other words, the namespace), representing the subject under which the schema will be registered, for example,
test-subject. - Credentials
Get
Subject Config Credentials - Rest
Endpoint string - The REST endpoint of the Schema Registry cluster, for example,
https://psrc-00000.us-central1.gcp.confluent.cloud:443). - Schema
Registry GetCluster Subject Config Schema Registry Cluster
- subject
Name String - The name of the subject (in other words, the namespace), representing the subject under which the schema will be registered, for example,
test-subject. - credentials
Get
Subject Config Credentials - rest
Endpoint String - The REST endpoint of the Schema Registry cluster, for example,
https://psrc-00000.us-central1.gcp.confluent.cloud:443). - schema
Registry GetCluster Subject Config Schema Registry Cluster
- subject
Name string - The name of the subject (in other words, the namespace), representing the subject under which the schema will be registered, for example,
test-subject. - credentials
Get
Subject Config Credentials - rest
Endpoint string - The REST endpoint of the Schema Registry cluster, for example,
https://psrc-00000.us-central1.gcp.confluent.cloud:443). - schema
Registry GetCluster Subject Config Schema Registry Cluster
- subject_
name str - The name of the subject (in other words, the namespace), representing the subject under which the schema will be registered, for example,
test-subject. - credentials
Get
Subject Config Credentials - rest_
endpoint str - The REST endpoint of the Schema Registry cluster, for example,
https://psrc-00000.us-central1.gcp.confluent.cloud:443). - schema_
registry_ Getcluster Subject Config Schema Registry Cluster
- subject
Name String - The name of the subject (in other words, the namespace), representing the subject under which the schema will be registered, for example,
test-subject. - credentials Property Map
- rest
Endpoint String - The REST endpoint of the Schema Registry cluster, for example,
https://psrc-00000.us-central1.gcp.confluent.cloud:443). - schema
Registry Property MapCluster
getSubjectConfig Result
The following output properties are available:
- Alias string
- (Optional String) The subject name that this subject is an alias for.
- Compatibility
Group string - (Optional String) The Compatibility Group of the specified subject.
- Compatibility
Level string - (Optional String) The Compatibility Level of the specified subject. Accepted values are:
BACKWARD,BACKWARD_TRANSITIVE,FORWARD,FORWARD_TRANSITIVE,FULL,FULL_TRANSITIVE, andNONE. See the Compatibility Types for more details. - Id string
- The provider-assigned unique ID for this managed resource.
- Normalize bool
- (Optional Boolean) Whether schemas are automatically normalized when registered or passed during lookups.
- Subject
Name string - Credentials
Pulumi.
Confluent Cloud. Outputs. Get Subject Config Credentials - Rest
Endpoint string - Schema
Registry Pulumi.Cluster Confluent Cloud. Outputs. Get Subject Config Schema Registry Cluster
- Alias string
- (Optional String) The subject name that this subject is an alias for.
- Compatibility
Group string - (Optional String) The Compatibility Group of the specified subject.
- Compatibility
Level string - (Optional String) The Compatibility Level of the specified subject. Accepted values are:
BACKWARD,BACKWARD_TRANSITIVE,FORWARD,FORWARD_TRANSITIVE,FULL,FULL_TRANSITIVE, andNONE. See the Compatibility Types for more details. - Id string
- The provider-assigned unique ID for this managed resource.
- Normalize bool
- (Optional Boolean) Whether schemas are automatically normalized when registered or passed during lookups.
- Subject
Name string - Credentials
Get
Subject Config Credentials - Rest
Endpoint string - Schema
Registry GetCluster Subject Config Schema Registry Cluster
- alias String
- (Optional String) The subject name that this subject is an alias for.
- compatibility
Group String - (Optional String) The Compatibility Group of the specified subject.
- compatibility
Level String - (Optional String) The Compatibility Level of the specified subject. Accepted values are:
BACKWARD,BACKWARD_TRANSITIVE,FORWARD,FORWARD_TRANSITIVE,FULL,FULL_TRANSITIVE, andNONE. See the Compatibility Types for more details. - id String
- The provider-assigned unique ID for this managed resource.
- normalize Boolean
- (Optional Boolean) Whether schemas are automatically normalized when registered or passed during lookups.
- subject
Name String - credentials
Get
Subject Config Credentials - rest
Endpoint String - schema
Registry GetCluster Subject Config Schema Registry Cluster
- alias string
- (Optional String) The subject name that this subject is an alias for.
- compatibility
Group string - (Optional String) The Compatibility Group of the specified subject.
- compatibility
Level string - (Optional String) The Compatibility Level of the specified subject. Accepted values are:
BACKWARD,BACKWARD_TRANSITIVE,FORWARD,FORWARD_TRANSITIVE,FULL,FULL_TRANSITIVE, andNONE. See the Compatibility Types for more details. - id string
- The provider-assigned unique ID for this managed resource.
- normalize boolean
- (Optional Boolean) Whether schemas are automatically normalized when registered or passed during lookups.
- subject
Name string - credentials
Get
Subject Config Credentials - rest
Endpoint string - schema
Registry GetCluster Subject Config Schema Registry Cluster
- alias str
- (Optional String) The subject name that this subject is an alias for.
- compatibility_
group str - (Optional String) The Compatibility Group of the specified subject.
- compatibility_
level str - (Optional String) The Compatibility Level of the specified subject. Accepted values are:
BACKWARD,BACKWARD_TRANSITIVE,FORWARD,FORWARD_TRANSITIVE,FULL,FULL_TRANSITIVE, andNONE. See the Compatibility Types for more details. - id str
- The provider-assigned unique ID for this managed resource.
- normalize bool
- (Optional Boolean) Whether schemas are automatically normalized when registered or passed during lookups.
- subject_
name str - credentials
Get
Subject Config Credentials - rest_
endpoint str - schema_
registry_ Getcluster Subject Config Schema Registry Cluster
- alias String
- (Optional String) The subject name that this subject is an alias for.
- compatibility
Group String - (Optional String) The Compatibility Group of the specified subject.
- compatibility
Level String - (Optional String) The Compatibility Level of the specified subject. Accepted values are:
BACKWARD,BACKWARD_TRANSITIVE,FORWARD,FORWARD_TRANSITIVE,FULL,FULL_TRANSITIVE, andNONE. See the Compatibility Types for more details. - id String
- The provider-assigned unique ID for this managed resource.
- normalize Boolean
- (Optional Boolean) Whether schemas are automatically normalized when registered or passed during lookups.
- subject
Name String - credentials Property Map
- rest
Endpoint String - schema
Registry Property MapCluster
Supporting Types
GetSubjectConfigCredentials
GetSubjectConfigSchemaRegistryCluster
- Id string
- The ID of the Schema Registry cluster, for example,
lsrc-abc123.
- Id string
- The ID of the Schema Registry cluster, for example,
lsrc-abc123.
- id String
- The ID of the Schema Registry cluster, for example,
lsrc-abc123.
- id string
- The ID of the Schema Registry cluster, for example,
lsrc-abc123.
- id str
- The ID of the Schema Registry cluster, for example,
lsrc-abc123.
- id String
- The ID of the Schema Registry cluster, for example,
lsrc-abc123.
Package Details
- Repository
- Confluent Cloud pulumi/pulumi-confluentcloud
- License
- Apache-2.0
- Notes
- This Pulumi package is based on the
confluentTerraform Provider.
Viewing docs for Confluent v2.61.0
published on Saturday, Mar 21, 2026 by Pulumi
published on Saturday, Mar 21, 2026 by Pulumi
