1. Packages
  2. Packages
  3. Aiven Provider
  4. API Docs
  5. KafkaTopic
Viewing docs for Aiven v5.6.0 (Older version)
published on Monday, Mar 9, 2026 by Pulumi
Go to latest version
Schema (JSON)
pulumi/pulumi-aiven

aiven.KafkaTopic

aiven logo
Viewing docs for Aiven v5.6.0 (Older version)
published on Monday, Mar 9, 2026 by Pulumi
Go to latest version
Schema (JSON)
pulumi/pulumi-aiven

    The Kafka Topic resource allows the creation and management of Aiven Kafka Topics.

    Example Usage

    Example coming soon!

    Example coming soon!

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aiven.KafkaTopic;
import com.pulumi.aiven.KafkaTopicArgs;
import com.pulumi.aiven.inputs.KafkaTopicConfigArgs;
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 mytesttopic = new KafkaTopic("mytesttopic", KafkaTopicArgs.builder()        
            .project(aiven_project.myproject().project())
            .serviceName(aiven_kafka.myservice().service_name())
            .topicName("<TOPIC_NAME>")
            .partitions(5)
            .replication(3)
            .terminationProtection(true)
            .config(KafkaTopicConfigArgs.builder()
                .flushMs(10)
                .uncleanLeaderElectionEnable(true)
                .cleanupPolicy("compact,delete")
                .build())
            .timeouts(%!v(PANIC=Format method: runtime error: invalid memory address or nil pointer dereference))
            .build());

    }
}

    Example coming soon!

    Example coming soon!

    resources:
  mytesttopic:
    type: aiven:KafkaTopic
    properties:
      project: ${aiven_project.myproject.project}
      serviceName: ${aiven_kafka.myservice.service_name}
      topicName: <TOPIC_NAME>
      partitions: 5
      replication: 3
      terminationProtection: true
      config:
        flushMs: 10
        uncleanLeaderElectionEnable: true
        cleanupPolicy: compact,delete
      timeouts:
        - create: 1m
          read: 5m

    Create KafkaTopic Resource

    Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.

    Constructor syntax

    new KafkaTopic(name: string, args: KafkaTopicArgs, opts?: CustomResourceOptions);
    @overload
def KafkaTopic(resource_name: str,
               args: KafkaTopicArgs,
               opts: Optional[ResourceOptions] = None)

@overload
def KafkaTopic(resource_name: str,
               opts: Optional[ResourceOptions] = None,
               partitions: Optional[int] = None,
               project: Optional[str] = None,
               replication: Optional[int] = None,
               service_name: Optional[str] = None,
               topic_name: Optional[str] = None,
               config: Optional[KafkaTopicConfigArgs] = None,
               tags: Optional[Sequence[KafkaTopicTagArgs]] = None,
               termination_protection: Optional[bool] = None)
    func NewKafkaTopic(ctx *Context, name string, args KafkaTopicArgs, opts ...ResourceOption) (*KafkaTopic, error)
    public KafkaTopic(string name, KafkaTopicArgs args, CustomResourceOptions? opts = null)
    public KafkaTopic(String name, KafkaTopicArgs args)
public KafkaTopic(String name, KafkaTopicArgs args, CustomResourceOptions options)

    type: aiven:KafkaTopic
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.

    Parameters

    name string
    The unique name of the resource.
    args KafkaTopicArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    resource_name str
    The unique name of the resource.
    args KafkaTopicArgs
    The arguments to resource properties.
    opts ResourceOptions
    Bag of options to control resource's behavior.
    ctx Context
    Context object for the current deployment.
    name string
    The unique name of the resource.
    args KafkaTopicArgs
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args KafkaTopicArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args KafkaTopicArgs
    The arguments to resource properties.
    options CustomResourceOptions
    Bag of options to control resource's behavior.

    Constructor example

    The following reference example uses placeholder values for all input properties.

    var kafkaTopicResource = new Aiven.KafkaTopic("kafkaTopicResource", new()
{
    Partitions = 0,
    Project = "string",
    Replication = 0,
    ServiceName = "string",
    TopicName = "string",
    Config = new Aiven.Inputs.KafkaTopicConfigArgs
    {
        CleanupPolicy = "string",
        CompressionType = "string",
        DeleteRetentionMs = "string",
        FileDeleteDelayMs = "string",
        FlushMessages = "string",
        FlushMs = "string",
        IndexIntervalBytes = "string",
        MaxCompactionLagMs = "string",
        MaxMessageBytes = "string",
        MessageDownconversionEnable = "string",
        MessageFormatVersion = "string",
        MessageTimestampDifferenceMaxMs = "string",
        MessageTimestampType = "string",
        MinCleanableDirtyRatio = "string",
        MinCompactionLagMs = "string",
        MinInsyncReplicas = "string",
        Preallocate = "string",
        RetentionBytes = "string",
        RetentionMs = "string",
        SegmentBytes = "string",
        SegmentIndexBytes = "string",
        SegmentJitterMs = "string",
        SegmentMs = "string",
        UncleanLeaderElectionEnable = "string",
    },
    Tags = new[]
    {
        new Aiven.Inputs.KafkaTopicTagArgs
        {
            Key = "string",
            Value = "string",
        },
    },
    TerminationProtection = false,
});

    example, err := aiven.NewKafkaTopic(ctx, "kafkaTopicResource", &aiven.KafkaTopicArgs{
	Partitions:  pulumi.Int(0),
	Project:     pulumi.String("string"),
	Replication: pulumi.Int(0),
	ServiceName: pulumi.String("string"),
	TopicName:   pulumi.String("string"),
	Config: &aiven.KafkaTopicConfigArgs{
		CleanupPolicy:                   pulumi.String("string"),
		CompressionType:                 pulumi.String("string"),
		DeleteRetentionMs:               pulumi.String("string"),
		FileDeleteDelayMs:               pulumi.String("string"),
		FlushMessages:                   pulumi.String("string"),
		FlushMs:                         pulumi.String("string"),
		IndexIntervalBytes:              pulumi.String("string"),
		MaxCompactionLagMs:              pulumi.String("string"),
		MaxMessageBytes:                 pulumi.String("string"),
		MessageDownconversionEnable:     pulumi.String("string"),
		MessageFormatVersion:            pulumi.String("string"),
		MessageTimestampDifferenceMaxMs: pulumi.String("string"),
		MessageTimestampType:            pulumi.String("string"),
		MinCleanableDirtyRatio:          pulumi.String("string"),
		MinCompactionLagMs:              pulumi.String("string"),
		MinInsyncReplicas:               pulumi.String("string"),
		Preallocate:                     pulumi.String("string"),
		RetentionBytes:                  pulumi.String("string"),
		RetentionMs:                     pulumi.String("string"),
		SegmentBytes:                    pulumi.String("string"),
		SegmentIndexBytes:               pulumi.String("string"),
		SegmentJitterMs:                 pulumi.String("string"),
		SegmentMs:                       pulumi.String("string"),
		UncleanLeaderElectionEnable:     pulumi.String("string"),
	},
	Tags: aiven.KafkaTopicTagArray{
		&aiven.KafkaTopicTagArgs{
			Key:   pulumi.String("string"),
			Value: pulumi.String("string"),
		},
	},
	TerminationProtection: pulumi.Bool(false),
})

    var kafkaTopicResource = new KafkaTopic("kafkaTopicResource", KafkaTopicArgs.builder()
    .partitions(0)
    .project("string")
    .replication(0)
    .serviceName("string")
    .topicName("string")
    .config(KafkaTopicConfigArgs.builder()
        .cleanupPolicy("string")
        .compressionType("string")
        .deleteRetentionMs("string")
        .fileDeleteDelayMs("string")
        .flushMessages("string")
        .flushMs("string")
        .indexIntervalBytes("string")
        .maxCompactionLagMs("string")
        .maxMessageBytes("string")
        .messageDownconversionEnable("string")
        .messageFormatVersion("string")
        .messageTimestampDifferenceMaxMs("string")
        .messageTimestampType("string")
        .minCleanableDirtyRatio("string")
        .minCompactionLagMs("string")
        .minInsyncReplicas("string")
        .preallocate("string")
        .retentionBytes("string")
        .retentionMs("string")
        .segmentBytes("string")
        .segmentIndexBytes("string")
        .segmentJitterMs("string")
        .segmentMs("string")
        .uncleanLeaderElectionEnable("string")
        .build())
    .tags(KafkaTopicTagArgs.builder()
        .key("string")
        .value("string")
        .build())
    .terminationProtection(false)
    .build());

    kafka_topic_resource = aiven.KafkaTopic("kafkaTopicResource",
    partitions=0,
    project="string",
    replication=0,
    service_name="string",
    topic_name="string",
    config={
        "cleanup_policy": "string",
        "compression_type": "string",
        "delete_retention_ms": "string",
        "file_delete_delay_ms": "string",
        "flush_messages": "string",
        "flush_ms": "string",
        "index_interval_bytes": "string",
        "max_compaction_lag_ms": "string",
        "max_message_bytes": "string",
        "message_downconversion_enable": "string",
        "message_format_version": "string",
        "message_timestamp_difference_max_ms": "string",
        "message_timestamp_type": "string",
        "min_cleanable_dirty_ratio": "string",
        "min_compaction_lag_ms": "string",
        "min_insync_replicas": "string",
        "preallocate": "string",
        "retention_bytes": "string",
        "retention_ms": "string",
        "segment_bytes": "string",
        "segment_index_bytes": "string",
        "segment_jitter_ms": "string",
        "segment_ms": "string",
        "unclean_leader_election_enable": "string",
    },
    tags=[{
        "key": "string",
        "value": "string",
    }],
    termination_protection=False)

    const kafkaTopicResource = new aiven.KafkaTopic("kafkaTopicResource", {
    partitions: 0,
    project: "string",
    replication: 0,
    serviceName: "string",
    topicName: "string",
    config: {
        cleanupPolicy: "string",
        compressionType: "string",
        deleteRetentionMs: "string",
        fileDeleteDelayMs: "string",
        flushMessages: "string",
        flushMs: "string",
        indexIntervalBytes: "string",
        maxCompactionLagMs: "string",
        maxMessageBytes: "string",
        messageDownconversionEnable: "string",
        messageFormatVersion: "string",
        messageTimestampDifferenceMaxMs: "string",
        messageTimestampType: "string",
        minCleanableDirtyRatio: "string",
        minCompactionLagMs: "string",
        minInsyncReplicas: "string",
        preallocate: "string",
        retentionBytes: "string",
        retentionMs: "string",
        segmentBytes: "string",
        segmentIndexBytes: "string",
        segmentJitterMs: "string",
        segmentMs: "string",
        uncleanLeaderElectionEnable: "string",
    },
    tags: [{
        key: "string",
        value: "string",
    }],
    terminationProtection: false,
});

    type: aiven:KafkaTopic
properties:
    config:
        cleanupPolicy: string
        compressionType: string
        deleteRetentionMs: string
        fileDeleteDelayMs: string
        flushMessages: string
        flushMs: string
        indexIntervalBytes: string
        maxCompactionLagMs: string
        maxMessageBytes: string
        messageDownconversionEnable: string
        messageFormatVersion: string
        messageTimestampDifferenceMaxMs: string
        messageTimestampType: string
        minCleanableDirtyRatio: string
        minCompactionLagMs: string
        minInsyncReplicas: string
        preallocate: string
        retentionBytes: string
        retentionMs: string
        segmentBytes: string
        segmentIndexBytes: string
        segmentJitterMs: string
        segmentMs: string
        uncleanLeaderElectionEnable: string
    partitions: 0
    project: string
    replication: 0
    serviceName: string
    tags:
        - key: string
          value: string
    terminationProtection: false
    topicName: string

    KafkaTopic Resource Properties

    To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.

    Inputs

    In Python, inputs that are objects can be passed either as argument classes or as dictionary literals.

    The KafkaTopic resource accepts the following input properties:

    Partitions int
    The number of partitions to create in the topic.
    Project string
    Identifies the project this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    Replication int
    The replication factor for the topic.
    ServiceName string
    Specifies the name of the service that this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    TopicName string
    The name of the topic. This property cannot be changed, doing so forces recreation of the resource.
    Config KafkaTopicConfig
    Kafka topic configuration
    Tags List<KafkaTopicTag>
    Kafka Topic tag.
    TerminationProtection bool
    It is a Terraform client-side deletion protection, which prevents a Kafka topic from being deleted. It is recommended to enable this for any production Kafka topic containing critical data.
    Partitions int
    The number of partitions to create in the topic.
    Project string
    Identifies the project this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    Replication int
    The replication factor for the topic.
    ServiceName string
    Specifies the name of the service that this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    TopicName string
    The name of the topic. This property cannot be changed, doing so forces recreation of the resource.
    Config KafkaTopicConfigArgs
    Kafka topic configuration
    Tags []KafkaTopicTagArgs
    Kafka Topic tag.
    TerminationProtection bool
    It is a Terraform client-side deletion protection, which prevents a Kafka topic from being deleted. It is recommended to enable this for any production Kafka topic containing critical data.
    partitions Integer
    The number of partitions to create in the topic.
    project String
    Identifies the project this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    replication Integer
    The replication factor for the topic.
    serviceName String
    Specifies the name of the service that this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    topicName String
    The name of the topic. This property cannot be changed, doing so forces recreation of the resource.
    config KafkaTopicConfig
    Kafka topic configuration
    tags List<KafkaTopicTag>
    Kafka Topic tag.
    terminationProtection Boolean
    It is a Terraform client-side deletion protection, which prevents a Kafka topic from being deleted. It is recommended to enable this for any production Kafka topic containing critical data.
    partitions number
    The number of partitions to create in the topic.
    project string
    Identifies the project this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    replication number
    The replication factor for the topic.
    serviceName string
    Specifies the name of the service that this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    topicName string
    The name of the topic. This property cannot be changed, doing so forces recreation of the resource.
    config KafkaTopicConfig
    Kafka topic configuration
    tags KafkaTopicTag[]
    Kafka Topic tag.
    terminationProtection boolean
    It is a Terraform client-side deletion protection, which prevents a Kafka topic from being deleted. It is recommended to enable this for any production Kafka topic containing critical data.
    partitions int
    The number of partitions to create in the topic.
    project str
    Identifies the project this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    replication int
    The replication factor for the topic.
    service_name str
    Specifies the name of the service that this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    topic_name str
    The name of the topic. This property cannot be changed, doing so forces recreation of the resource.
    config KafkaTopicConfigArgs
    Kafka topic configuration
    tags Sequence[KafkaTopicTagArgs]
    Kafka Topic tag.
    termination_protection bool
    It is a Terraform client-side deletion protection, which prevents a Kafka topic from being deleted. It is recommended to enable this for any production Kafka topic containing critical data.
    partitions Number
    The number of partitions to create in the topic.
    project String
    Identifies the project this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    replication Number
    The replication factor for the topic.
    serviceName String
    Specifies the name of the service that this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    topicName String
    The name of the topic. This property cannot be changed, doing so forces recreation of the resource.
    config Property Map
    Kafka topic configuration
    tags List<Property Map>
    Kafka Topic tag.
    terminationProtection Boolean
    It is a Terraform client-side deletion protection, which prevents a Kafka topic from being deleted. It is recommended to enable this for any production Kafka topic containing critical data.

    Outputs

    All input properties are implicitly available as output properties. Additionally, the KafkaTopic resource produces the following output properties:

    Id string
    The provider-assigned unique ID for this managed resource.
    Id string
    The provider-assigned unique ID for this managed resource.
    id String
    The provider-assigned unique ID for this managed resource.
    id string
    The provider-assigned unique ID for this managed resource.
    id str
    The provider-assigned unique ID for this managed resource.
    id String
    The provider-assigned unique ID for this managed resource.

    Look up Existing KafkaTopic Resource

    Get an existing KafkaTopic resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

    public static get(name: string, id: Input<ID>, state?: KafkaTopicState, opts?: CustomResourceOptions): KafkaTopic
    @staticmethod
def get(resource_name: str,
        id: str,
        opts: Optional[ResourceOptions] = None,
        config: Optional[KafkaTopicConfigArgs] = None,
        partitions: Optional[int] = None,
        project: Optional[str] = None,
        replication: Optional[int] = None,
        service_name: Optional[str] = None,
        tags: Optional[Sequence[KafkaTopicTagArgs]] = None,
        termination_protection: Optional[bool] = None,
        topic_name: Optional[str] = None) -> KafkaTopic
    func GetKafkaTopic(ctx *Context, name string, id IDInput, state *KafkaTopicState, opts ...ResourceOption) (*KafkaTopic, error)
    public static KafkaTopic Get(string name, Input<string> id, KafkaTopicState? state, CustomResourceOptions? opts = null)
    public static KafkaTopic get(String name, Output<String> id, KafkaTopicState state, CustomResourceOptions options)
    resources:  _:    type: aiven:KafkaTopic    get:      id: ${id}
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    resource_name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    The following state arguments are supported:
    Config KafkaTopicConfig
    Kafka topic configuration
    Partitions int
    The number of partitions to create in the topic.
    Project string
    Identifies the project this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    Replication int
    The replication factor for the topic.
    ServiceName string
    Specifies the name of the service that this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    Tags List<KafkaTopicTag>
    Kafka Topic tag.
    TerminationProtection bool
    It is a Terraform client-side deletion protection, which prevents a Kafka topic from being deleted. It is recommended to enable this for any production Kafka topic containing critical data.
    TopicName string
    The name of the topic. This property cannot be changed, doing so forces recreation of the resource.
    Config KafkaTopicConfigArgs
    Kafka topic configuration
    Partitions int
    The number of partitions to create in the topic.
    Project string
    Identifies the project this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    Replication int
    The replication factor for the topic.
    ServiceName string
    Specifies the name of the service that this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    Tags []KafkaTopicTagArgs
    Kafka Topic tag.
    TerminationProtection bool
    It is a Terraform client-side deletion protection, which prevents a Kafka topic from being deleted. It is recommended to enable this for any production Kafka topic containing critical data.
    TopicName string
    The name of the topic. This property cannot be changed, doing so forces recreation of the resource.
    config KafkaTopicConfig
    Kafka topic configuration
    partitions Integer
    The number of partitions to create in the topic.
    project String
    Identifies the project this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    replication Integer
    The replication factor for the topic.
    serviceName String
    Specifies the name of the service that this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    tags List<KafkaTopicTag>
    Kafka Topic tag.
    terminationProtection Boolean
    It is a Terraform client-side deletion protection, which prevents a Kafka topic from being deleted. It is recommended to enable this for any production Kafka topic containing critical data.
    topicName String
    The name of the topic. This property cannot be changed, doing so forces recreation of the resource.
    config KafkaTopicConfig
    Kafka topic configuration
    partitions number
    The number of partitions to create in the topic.
    project string
    Identifies the project this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    replication number
    The replication factor for the topic.
    serviceName string
    Specifies the name of the service that this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    tags KafkaTopicTag[]
    Kafka Topic tag.
    terminationProtection boolean
    It is a Terraform client-side deletion protection, which prevents a Kafka topic from being deleted. It is recommended to enable this for any production Kafka topic containing critical data.
    topicName string
    The name of the topic. This property cannot be changed, doing so forces recreation of the resource.
    config KafkaTopicConfigArgs
    Kafka topic configuration
    partitions int
    The number of partitions to create in the topic.
    project str
    Identifies the project this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    replication int
    The replication factor for the topic.
    service_name str
    Specifies the name of the service that this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    tags Sequence[KafkaTopicTagArgs]
    Kafka Topic tag.
    termination_protection bool
    It is a Terraform client-side deletion protection, which prevents a Kafka topic from being deleted. It is recommended to enable this for any production Kafka topic containing critical data.
    topic_name str
    The name of the topic. This property cannot be changed, doing so forces recreation of the resource.
    config Property Map
    Kafka topic configuration
    partitions Number
    The number of partitions to create in the topic.
    project String
    Identifies the project this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    replication Number
    The replication factor for the topic.
    serviceName String
    Specifies the name of the service that this resource belongs to. To set up proper dependencies please refer to this variable as a reference. This property cannot be changed, doing so forces recreation of the resource.
    tags List<Property Map>
    Kafka Topic tag.
    terminationProtection Boolean
    It is a Terraform client-side deletion protection, which prevents a Kafka topic from being deleted. It is recommended to enable this for any production Kafka topic containing critical data.
    topicName String
    The name of the topic. This property cannot be changed, doing so forces recreation of the resource.

    Supporting Types

    KafkaTopicConfig, KafkaTopicConfigArgs

    CleanupPolicy string
    cleanup.policy value
    CompressionType string
    compression.type value
    DeleteRetentionMs string
    delete.retention.ms value
    FileDeleteDelayMs string
    file.delete.delay.ms value
    FlushMessages string
    flush.messages value
    FlushMs string
    flush.ms value
    IndexIntervalBytes string
    index.interval.bytes value
    MaxCompactionLagMs string
    max.compaction.lag.ms value
    MaxMessageBytes string
    max.message.bytes value
    MessageDownconversionEnable string
    message.downconversion.enable value
    MessageFormatVersion string
    message.format.version value
    MessageTimestampDifferenceMaxMs string
    message.timestamp.difference.max.ms value
    MessageTimestampType string
    message.timestamp.type value
    MinCleanableDirtyRatio string
    min.cleanable.dirty.ratio value
    MinCompactionLagMs string
    min.compaction.lag.ms value
    MinInsyncReplicas string
    min.insync.replicas value
    Preallocate string
    preallocate value
    RetentionBytes string
    retention.bytes value
    RetentionMs string
    retention.ms value
    SegmentBytes string
    segment.bytes value
    SegmentIndexBytes string
    segment.index.bytes value
    SegmentJitterMs string
    segment.jitter.ms value
    SegmentMs string
    segment.ms value
    UncleanLeaderElectionEnable string
    unclean.leader.election.enable value
    CleanupPolicy string
    cleanup.policy value
    CompressionType string
    compression.type value
    DeleteRetentionMs string
    delete.retention.ms value
    FileDeleteDelayMs string
    file.delete.delay.ms value
    FlushMessages string
    flush.messages value
    FlushMs string
    flush.ms value
    IndexIntervalBytes string
    index.interval.bytes value
    MaxCompactionLagMs string
    max.compaction.lag.ms value
    MaxMessageBytes string
    max.message.bytes value
    MessageDownconversionEnable string
    message.downconversion.enable value
    MessageFormatVersion string
    message.format.version value
    MessageTimestampDifferenceMaxMs string
    message.timestamp.difference.max.ms value
    MessageTimestampType string
    message.timestamp.type value
    MinCleanableDirtyRatio string
    min.cleanable.dirty.ratio value
    MinCompactionLagMs string
    min.compaction.lag.ms value
    MinInsyncReplicas string
    min.insync.replicas value
    Preallocate string
    preallocate value
    RetentionBytes string
    retention.bytes value
    RetentionMs string
    retention.ms value
    SegmentBytes string
    segment.bytes value
    SegmentIndexBytes string
    segment.index.bytes value
    SegmentJitterMs string
    segment.jitter.ms value
    SegmentMs string
    segment.ms value
    UncleanLeaderElectionEnable string
    unclean.leader.election.enable value
    cleanupPolicy String
    cleanup.policy value
    compressionType String
    compression.type value
    deleteRetentionMs String
    delete.retention.ms value
    fileDeleteDelayMs String
    file.delete.delay.ms value
    flushMessages String
    flush.messages value
    flushMs String
    flush.ms value
    indexIntervalBytes String
    index.interval.bytes value
    maxCompactionLagMs String
    max.compaction.lag.ms value
    maxMessageBytes String
    max.message.bytes value
    messageDownconversionEnable String
    message.downconversion.enable value
    messageFormatVersion String
    message.format.version value
    messageTimestampDifferenceMaxMs String
    message.timestamp.difference.max.ms value
    messageTimestampType String
    message.timestamp.type value
    minCleanableDirtyRatio String
    min.cleanable.dirty.ratio value
    minCompactionLagMs String
    min.compaction.lag.ms value
    minInsyncReplicas String
    min.insync.replicas value
    preallocate String
    preallocate value
    retentionBytes String
    retention.bytes value
    retentionMs String
    retention.ms value
    segmentBytes String
    segment.bytes value
    segmentIndexBytes String
    segment.index.bytes value
    segmentJitterMs String
    segment.jitter.ms value
    segmentMs String
    segment.ms value
    uncleanLeaderElectionEnable String
    unclean.leader.election.enable value
    cleanupPolicy string
    cleanup.policy value
    compressionType string
    compression.type value
    deleteRetentionMs string
    delete.retention.ms value
    fileDeleteDelayMs string
    file.delete.delay.ms value
    flushMessages string
    flush.messages value
    flushMs string
    flush.ms value
    indexIntervalBytes string
    index.interval.bytes value
    maxCompactionLagMs string
    max.compaction.lag.ms value
    maxMessageBytes string
    max.message.bytes value
    messageDownconversionEnable string
    message.downconversion.enable value
    messageFormatVersion string
    message.format.version value
    messageTimestampDifferenceMaxMs string
    message.timestamp.difference.max.ms value
    messageTimestampType string
    message.timestamp.type value
    minCleanableDirtyRatio string
    min.cleanable.dirty.ratio value
    minCompactionLagMs string
    min.compaction.lag.ms value
    minInsyncReplicas string
    min.insync.replicas value
    preallocate string
    preallocate value
    retentionBytes string
    retention.bytes value
    retentionMs string
    retention.ms value
    segmentBytes string
    segment.bytes value
    segmentIndexBytes string
    segment.index.bytes value
    segmentJitterMs string
    segment.jitter.ms value
    segmentMs string
    segment.ms value
    uncleanLeaderElectionEnable string
    unclean.leader.election.enable value
    cleanup_policy str
    cleanup.policy value
    compression_type str
    compression.type value
    delete_retention_ms str
    delete.retention.ms value
    file_delete_delay_ms str
    file.delete.delay.ms value
    flush_messages str
    flush.messages value
    flush_ms str
    flush.ms value
    index_interval_bytes str
    index.interval.bytes value
    max_compaction_lag_ms str
    max.compaction.lag.ms value
    max_message_bytes str
    max.message.bytes value
    message_downconversion_enable str
    message.downconversion.enable value
    message_format_version str
    message.format.version value
    message_timestamp_difference_max_ms str
    message.timestamp.difference.max.ms value
    message_timestamp_type str
    message.timestamp.type value
    min_cleanable_dirty_ratio str
    min.cleanable.dirty.ratio value
    min_compaction_lag_ms str
    min.compaction.lag.ms value
    min_insync_replicas str
    min.insync.replicas value
    preallocate str
    preallocate value
    retention_bytes str
    retention.bytes value
    retention_ms str
    retention.ms value
    segment_bytes str
    segment.bytes value
    segment_index_bytes str
    segment.index.bytes value
    segment_jitter_ms str
    segment.jitter.ms value
    segment_ms str
    segment.ms value
    unclean_leader_election_enable str
    unclean.leader.election.enable value
    cleanupPolicy String
    cleanup.policy value
    compressionType String
    compression.type value
    deleteRetentionMs String
    delete.retention.ms value
    fileDeleteDelayMs String
    file.delete.delay.ms value
    flushMessages String
    flush.messages value
    flushMs String
    flush.ms value
    indexIntervalBytes String
    index.interval.bytes value
    maxCompactionLagMs String
    max.compaction.lag.ms value
    maxMessageBytes String
    max.message.bytes value
    messageDownconversionEnable String
    message.downconversion.enable value
    messageFormatVersion String
    message.format.version value
    messageTimestampDifferenceMaxMs String
    message.timestamp.difference.max.ms value
    messageTimestampType String
    message.timestamp.type value
    minCleanableDirtyRatio String
    min.cleanable.dirty.ratio value
    minCompactionLagMs String
    min.compaction.lag.ms value
    minInsyncReplicas String
    min.insync.replicas value
    preallocate String
    preallocate value
    retentionBytes String
    retention.bytes value
    retentionMs String
    retention.ms value
    segmentBytes String
    segment.bytes value
    segmentIndexBytes String
    segment.index.bytes value
    segmentJitterMs String
    segment.jitter.ms value
    segmentMs String
    segment.ms value
    uncleanLeaderElectionEnable String
    unclean.leader.election.enable value

    KafkaTopicTag, KafkaTopicTagArgs

    Key string
    Topic tag key. Maximum Length: 64.
    Value string
    Topic tag value. Maximum Length: 256.
    Key string
    Topic tag key. Maximum Length: 64.
    Value string
    Topic tag value. Maximum Length: 256.
    key String
    Topic tag key. Maximum Length: 64.
    value String
    Topic tag value. Maximum Length: 256.
    key string
    Topic tag key. Maximum Length: 64.
    value string
    Topic tag value. Maximum Length: 256.
    key str
    Topic tag key. Maximum Length: 64.
    value str
    Topic tag value. Maximum Length: 256.
    key String
    Topic tag key. Maximum Length: 64.
    value String
    Topic tag value. Maximum Length: 256.

    Import

     $ pulumi import aiven:index/kafkaTopic:KafkaTopic mytesttopic project/service_name/topic_name

    To learn more about importing existing cloud resources, see Importing resources.

    Package Details

    Repository
    Aiven pulumi/pulumi-aiven
    License
    Apache-2.0
    Notes
    This Pulumi package is based on the aiven Terraform Provider.
    aiven logo
    Viewing docs for Aiven v5.6.0 (Older version)
    published on Monday, Mar 9, 2026 by Pulumi
    Go to latest version
    Schema (JSON)
    pulumi/pulumi-aiven
      Try Pulumi Cloud free. Your team will thank you.