TopicArgs

data class TopicArgs(val clusterId: Output<String>? = null, val configs: Output<TopicsRelatedLinkArgs>? = null, val environmentId: Output<String>? = null, val inputConfigs: Output<List<TopicsInputConfigArgs>>? = null, val kind: Output<String>? = null, val metadata: Output<TopicMetadataEntityArgs>? = null, val organizationName: Output<String>? = null, val partitions: Output<TopicsRelatedLinkArgs>? = null, val partitionsCount: Output<String>? = null, val partitionsReassignments: Output<TopicsRelatedLinkArgs>? = null, val replicationFactor: Output<String>? = null, val resourceGroupName: Output<String>? = null, val topicId: Output<String>? = null, val topicName: Output<String>? = null) : ConvertibleToJava<TopicArgs>

Details of topic record Uses Azure REST API version 2024-07-01. In version 2.x of the Azure Native provider, it used API version 2024-07-01.

Example Usage

Topics_Create

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AzureNative = Pulumi.AzureNative;
return await Deployment.RunAsync(() =>
{
var topic = new AzureNative.Confluent.Topic("topic", new()
{
ClusterId = "dlz-f3a90de",
EnvironmentId = "env-12132",
InputConfigs = new[]
{
new AzureNative.Confluent.Inputs.TopicsInputConfigArgs
{
Name = "cleanup.policy",
Value = "compact",
},
new AzureNative.Confluent.Inputs.TopicsInputConfigArgs
{
Name = "retention.ms",
Value = "86400000",
},
},
OrganizationName = "myOrganization",
PartitionsCount = "1",
ReplicationFactor = "3",
ResourceGroupName = "myResourceGroup",
TopicName = "topic-1",
});
});
package main
import (
confluent "github.com/pulumi/pulumi-azure-native-sdk/confluent/v2"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := confluent.NewTopic(ctx, "topic", &confluent.TopicArgs{
ClusterId: pulumi.String("dlz-f3a90de"),
EnvironmentId: pulumi.String("env-12132"),
InputConfigs: confluent.TopicsInputConfigArray{
&confluent.TopicsInputConfigArgs{
Name: pulumi.String("cleanup.policy"),
Value: pulumi.String("compact"),
},
&confluent.TopicsInputConfigArgs{
Name: pulumi.String("retention.ms"),
Value: pulumi.String("86400000"),
},
},
OrganizationName: pulumi.String("myOrganization"),
PartitionsCount: pulumi.String("1"),
ReplicationFactor: pulumi.String("3"),
ResourceGroupName: pulumi.String("myResourceGroup"),
TopicName: pulumi.String("topic-1"),
})
if err != nil {
return err
}
return nil
})
}
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azurenative.confluent.Topic;
import com.pulumi.azurenative.confluent.TopicArgs;
import com.pulumi.azurenative.confluent.inputs.TopicsInputConfigArgs;
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) {
var topic = new Topic("topic", TopicArgs.builder()
.clusterId("dlz-f3a90de")
.environmentId("env-12132")
.inputConfigs(
TopicsInputConfigArgs.builder()
.name("cleanup.policy")
.value("compact")
.build(),
TopicsInputConfigArgs.builder()
.name("retention.ms")
.value("86400000")
.build())
.organizationName("myOrganization")
.partitionsCount("1")
.replicationFactor("3")
.resourceGroupName("myResourceGroup")
.topicName("topic-1")
.build());
}
}

Import

An existing resource can be imported using its type token, name, and identifier, e.g.

$ pulumi import azure-native:confluent:Topic topic-1 /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Confluent/organizations/{organizationName}/environments/{environmentId}/clusters/{clusterId}/topics/{topicName}

Constructors

Link copied to clipboard
constructor(clusterId: Output<String>? = null, configs: Output<TopicsRelatedLinkArgs>? = null, environmentId: Output<String>? = null, inputConfigs: Output<List<TopicsInputConfigArgs>>? = null, kind: Output<String>? = null, metadata: Output<TopicMetadataEntityArgs>? = null, organizationName: Output<String>? = null, partitions: Output<TopicsRelatedLinkArgs>? = null, partitionsCount: Output<String>? = null, partitionsReassignments: Output<TopicsRelatedLinkArgs>? = null, replicationFactor: Output<String>? = null, resourceGroupName: Output<String>? = null, topicId: Output<String>? = null, topicName: Output<String>? = null)

Properties

Link copied to clipboard
val clusterId: Output<String>? = null

Confluent kafka or schema registry cluster id

Link copied to clipboard
val configs: Output<TopicsRelatedLinkArgs>? = null

Config Specification of the topic

Link copied to clipboard
val environmentId: Output<String>? = null

Confluent environment id

Link copied to clipboard

Input Config Specification of the topic

Link copied to clipboard
val kind: Output<String>? = null

Type of topic

Link copied to clipboard
val metadata: Output<TopicMetadataEntityArgs>? = null

Metadata of the record

Link copied to clipboard
val organizationName: Output<String>? = null

Organization resource name

Link copied to clipboard
val partitions: Output<TopicsRelatedLinkArgs>? = null

Partition Specification of the topic

Link copied to clipboard
val partitionsCount: Output<String>? = null

Partition count of the topic

Link copied to clipboard

Partition Reassignment Specification of the topic

Link copied to clipboard
val replicationFactor: Output<String>? = null

Replication factor of the topic

Link copied to clipboard
val resourceGroupName: Output<String>? = null

The name of the resource group. The name is case insensitive.

Link copied to clipboard
val topicId: Output<String>? = null

Topic Id returned by Confluent

Link copied to clipboard
val topicName: Output<String>? = null

Confluent kafka or schema registry topic name

Functions

Link copied to clipboard
open override fun toJava(): TopicArgs