Sign in Dashboard Get started
  1. Registry
  2. Packages
  3. Aiven Provider
  4. API Docs
  5. MirrorMakerReplicationFlow
Viewing docs for Aiven v6.59.0
published on Thursday, Sep 17, 2026 by Pulumi
Schema (JSON)
pulumi/pulumi-aiven

aiven.MirrorMakerReplicationFlow

aiven logo aiven logo
Viewing docs for Aiven v6.59.0
published on Thursday, Sep 17, 2026 by Pulumi
Schema (JSON)
pulumi/pulumi-aiven

    Creates and manages an Aiven for Apache Kafka® MirrorMaker 2 replication flow. If this resource is missing (for example, after a service power off), it’s removed from the state and a new create plan is generated.

    Example Usage

    import * as pulumi from "@pulumi/pulumi";
import * as aiven from "@pulumi/aiven";

const example = new aiven.MirrorMakerReplicationFlow("example", {
    project: "my-project",
    serviceName: "foo",
    sourceCluster: "kafka-abc",
    targetCluster: "kafka-abc",
    enable: true,
    configPropertiesExcludes: [
        "follower.replication.throttled.replicas",
        "leader.replication.throttled.replicas",
        "message.timestamp.difference.max.ms",
        "message.timestamp.type",
        "unclean.leader.election.enable",
        "min.insync.replicas",
    ],
    emitBackwardHeartbeatsEnabled: false,
    emitHeartbeatsEnabled: false,
    exactlyOnceDeliveryEnabled: false,
    followerFetchingEnabled: true,
    offsetLagMax: 42,
    offsetSyncsTopicLocation: "source",
    replicationFactor: 1,
    replicationPolicyClass: "org.apache.kafka.connect.mirror.DefaultReplicationPolicy",
    syncGroupOffsetsEnabled: false,
    syncGroupOffsetsIntervalSeconds: 1,
    topics: [".*"],
    topicsBlacklists: [
        ".*[\\-\\.]internal",
        ".*\\.replica",
        "__.*",
    ],
});

    import pulumi
import pulumi_aiven as aiven

example = aiven.MirrorMakerReplicationFlow("example",
    project="my-project",
    service_name="foo",
    source_cluster="kafka-abc",
    target_cluster="kafka-abc",
    enable=True,
    config_properties_excludes=[
        "follower.replication.throttled.replicas",
        "leader.replication.throttled.replicas",
        "message.timestamp.difference.max.ms",
        "message.timestamp.type",
        "unclean.leader.election.enable",
        "min.insync.replicas",
    ],
    emit_backward_heartbeats_enabled=False,
    emit_heartbeats_enabled=False,
    exactly_once_delivery_enabled=False,
    follower_fetching_enabled=True,
    offset_lag_max=42,
    offset_syncs_topic_location="source",
    replication_factor=1,
    replication_policy_class="org.apache.kafka.connect.mirror.DefaultReplicationPolicy",
    sync_group_offsets_enabled=False,
    sync_group_offsets_interval_seconds=1,
    topics=[".*"],
    topics_blacklists=[
        ".*[\\-\\.]internal",
        ".*\\.replica",
        "__.*",
    ])

    package main

import (
	"github.com/pulumi/pulumi-aiven/sdk/v6/go/aiven"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := aiven.NewMirrorMakerReplicationFlow(ctx, "example", &aiven.MirrorMakerReplicationFlowArgs{
			Project:       pulumi.String("my-project"),
			ServiceName:   pulumi.String("foo"),
			SourceCluster: pulumi.String("kafka-abc"),
			TargetCluster: pulumi.String("kafka-abc"),
			Enable:        pulumi.Bool(true),
			ConfigPropertiesExcludes: pulumi.StringArray{
				pulumi.String("follower.replication.throttled.replicas"),
				pulumi.String("leader.replication.throttled.replicas"),
				pulumi.String("message.timestamp.difference.max.ms"),
				pulumi.String("message.timestamp.type"),
				pulumi.String("unclean.leader.election.enable"),
				pulumi.String("min.insync.replicas"),
			},
			EmitBackwardHeartbeatsEnabled:   pulumi.Bool(false),
			EmitHeartbeatsEnabled:           pulumi.Bool(false),
			ExactlyOnceDeliveryEnabled:      pulumi.Bool(false),
			FollowerFetchingEnabled:         pulumi.Bool(true),
			OffsetLagMax:                    pulumi.Int(42),
			OffsetSyncsTopicLocation:        pulumi.String("source"),
			ReplicationFactor:               pulumi.Int(1),
			ReplicationPolicyClass:          pulumi.String("org.apache.kafka.connect.mirror.DefaultReplicationPolicy"),
			SyncGroupOffsetsEnabled:         pulumi.Bool(false),
			SyncGroupOffsetsIntervalSeconds: pulumi.Int(1),
			Topics: pulumi.StringArray{
				pulumi.String(".*"),
			},
			TopicsBlacklists: pulumi.StringArray{
				pulumi.String(".*[\\-\\.]internal"),
				pulumi.String(".*\\.replica"),
				pulumi.String("__.*"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

    using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aiven = Pulumi.Aiven;

return await Deployment.RunAsync(() => 
{
    var example = new Aiven.MirrorMakerReplicationFlow("example", new()
    {
        Project = "my-project",
        ServiceName = "foo",
        SourceCluster = "kafka-abc",
        TargetCluster = "kafka-abc",
        Enable = true,
        ConfigPropertiesExcludes = new[]
        {
            "follower.replication.throttled.replicas",
            "leader.replication.throttled.replicas",
            "message.timestamp.difference.max.ms",
            "message.timestamp.type",
            "unclean.leader.election.enable",
            "min.insync.replicas",
        },
        EmitBackwardHeartbeatsEnabled = false,
        EmitHeartbeatsEnabled = false,
        ExactlyOnceDeliveryEnabled = false,
        FollowerFetchingEnabled = true,
        OffsetLagMax = 42,
        OffsetSyncsTopicLocation = "source",
        ReplicationFactor = 1,
        ReplicationPolicyClass = "org.apache.kafka.connect.mirror.DefaultReplicationPolicy",
        SyncGroupOffsetsEnabled = false,
        SyncGroupOffsetsIntervalSeconds = 1,
        Topics = new[]
        {
            ".*",
        },
        TopicsBlacklists = new[]
        {
            ".*[\\-\\.]internal",
            ".*\\.replica",
            "__.*",
        },
    });

});

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aiven.MirrorMakerReplicationFlow;
import com.pulumi.aiven.MirrorMakerReplicationFlowArgs;
import java.util.ArrayList;
import java.util.Arrays;
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 example = new MirrorMakerReplicationFlow("example", MirrorMakerReplicationFlowArgs.builder()
            .project("my-project")
            .serviceName("foo")
            .sourceCluster("kafka-abc")
            .targetCluster("kafka-abc")
            .enable(true)
            .configPropertiesExcludes(            
                "follower.replication.throttled.replicas",
                "leader.replication.throttled.replicas",
                "message.timestamp.difference.max.ms",
                "message.timestamp.type",
                "unclean.leader.election.enable",
                "min.insync.replicas")
            .emitBackwardHeartbeatsEnabled(false)
            .emitHeartbeatsEnabled(false)
            .exactlyOnceDeliveryEnabled(false)
            .followerFetchingEnabled(true)
            .offsetLagMax(42)
            .offsetSyncsTopicLocation("source")
            .replicationFactor(1)
            .replicationPolicyClass("org.apache.kafka.connect.mirror.DefaultReplicationPolicy")
            .syncGroupOffsetsEnabled(false)
            .syncGroupOffsetsIntervalSeconds(1)
            .topics(".*")
            .topicsBlacklists(            
                ".*[\\-\\.]internal",
                ".*\\.replica",
                "__.*")
            .build());

    }
}

    resources:
  example:
    type: aiven:MirrorMakerReplicationFlow
    properties:
      project: my-project
      serviceName: foo
      sourceCluster: kafka-abc
      targetCluster: kafka-abc
      enable: true # OPTIONAL FIELDS
      configPropertiesExcludes:
        - follower.replication.throttled.replicas
        - leader.replication.throttled.replicas
        - message.timestamp.difference.max.ms
        - message.timestamp.type
        - unclean.leader.election.enable
        - min.insync.replicas
      emitBackwardHeartbeatsEnabled: false
      emitHeartbeatsEnabled: false
      exactlyOnceDeliveryEnabled: false
      followerFetchingEnabled: true
      offsetLagMax: 42
      offsetSyncsTopicLocation: source
      replicationFactor: 1
      replicationPolicyClass: org.apache.kafka.connect.mirror.DefaultReplicationPolicy
      syncGroupOffsetsEnabled: false
      syncGroupOffsetsIntervalSeconds: 1
      topics:
        - .*
      topicsBlacklists:
        - .*[\-\.]internal
        - .*\.replica
        - __.*

    pulumi {
  required_providers {
    aiven = {
      source = "pulumi/aiven"
    }
  }
}

resource "aiven_mirrormakerreplicationflow" "example" {
  project        = "my-project"
  service_name   = "foo"
  source_cluster = "kafka-abc"
  target_cluster = "kafka-abc"
  enable         = true
  // OPTIONAL FIELDS
  config_properties_excludes          = ["follower.replication.throttled.replicas", "leader.replication.throttled.replicas", "message.timestamp.difference.max.ms", "message.timestamp.type", "unclean.leader.election.enable", "min.insync.replicas"]
  emit_backward_heartbeats_enabled    = false
  emit_heartbeats_enabled             = false
  exactly_once_delivery_enabled       = false
  follower_fetching_enabled           = true
  offset_lag_max                      = 42
  offset_syncs_topic_location         = "source"
  replication_factor                  = 1
  replication_policy_class            = "org.apache.kafka.connect.mirror.DefaultReplicationPolicy"
  sync_group_offsets_enabled          = false
  sync_group_offsets_interval_seconds = 1
  topics                              = [".*"]
  topics_blacklists                   = [".*[\\-\\.]internal", ".*\\.replica", "__.*"]
}

    Create MirrorMakerReplicationFlow Resource

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

    Constructor syntax

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

@overload
def MirrorMakerReplicationFlow(resource_name: str,
                               opts: Optional[ResourceOptions] = None,
                               source_cluster: Optional[str] = None,
                               project: Optional[str] = None,
                               target_cluster: Optional[str] = None,
                               service_name: Optional[str] = None,
                               enable: Optional[bool] = None,
                               replication_policy_class: Optional[str] = None,
                               config_properties_excludes: Optional[Sequence[str]] = None,
                               offset_syncs_topic_location: Optional[str] = None,
                               emit_backward_heartbeats_enabled: Optional[bool] = None,
                               follower_fetching_enabled: Optional[bool] = None,
                               exactly_once_delivery_enabled: Optional[bool] = None,
                               replication_factor: Optional[int] = None,
                               offset_lag_max: Optional[int] = None,
                               sync_group_offsets_enabled: Optional[bool] = None,
                               sync_group_offsets_interval_seconds: Optional[int] = None,
                               emit_heartbeats_enabled: Optional[bool] = None,
                               timeouts: Optional[MirrorMakerReplicationFlowTimeoutsArgs] = None,
                               topics: Optional[Sequence[str]] = None,
                               topics_blacklists: Optional[Sequence[str]] = None)
    func NewMirrorMakerReplicationFlow(ctx *Context, name string, args MirrorMakerReplicationFlowArgs, opts ...ResourceOption) (*MirrorMakerReplicationFlow, error)
    public MirrorMakerReplicationFlow(string name, MirrorMakerReplicationFlowArgs args, CustomResourceOptions? opts = null)
    public MirrorMakerReplicationFlow(String name, MirrorMakerReplicationFlowArgs args)
public MirrorMakerReplicationFlow(String name, MirrorMakerReplicationFlowArgs args, CustomResourceOptions options)

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


    resource "aiven_mirror_maker_replication_flow" "name" {
    # resource properties
}

    Parameters

    name string
    The unique name of the resource.
    args MirrorMakerReplicationFlowArgs
    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 MirrorMakerReplicationFlowArgs
    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 MirrorMakerReplicationFlowArgs
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args MirrorMakerReplicationFlowArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args MirrorMakerReplicationFlowArgs
    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 mirrorMakerReplicationFlowResource = new Aiven.MirrorMakerReplicationFlow("mirrorMakerReplicationFlowResource", new()
{
    SourceCluster = "string",
    Project = "string",
    TargetCluster = "string",
    ServiceName = "string",
    Enable = false,
    ReplicationPolicyClass = "string",
    ConfigPropertiesExcludes = new[]
    {
        "string",
    },
    OffsetSyncsTopicLocation = "string",
    EmitBackwardHeartbeatsEnabled = false,
    FollowerFetchingEnabled = false,
    ExactlyOnceDeliveryEnabled = false,
    ReplicationFactor = 0,
    OffsetLagMax = 0,
    SyncGroupOffsetsEnabled = false,
    SyncGroupOffsetsIntervalSeconds = 0,
    EmitHeartbeatsEnabled = false,
    Timeouts = new Aiven.Inputs.MirrorMakerReplicationFlowTimeoutsArgs
    {
        Create = "string",
        Delete = "string",
        Read = "string",
        Update = "string",
    },
    Topics = new[]
    {
        "string",
    },
    TopicsBlacklists = new[]
    {
        "string",
    },
});

    example, err := aiven.NewMirrorMakerReplicationFlow(ctx, "mirrorMakerReplicationFlowResource", &aiven.MirrorMakerReplicationFlowArgs{
	SourceCluster:          pulumi.String("string"),
	Project:                pulumi.String("string"),
	TargetCluster:          pulumi.String("string"),
	ServiceName:            pulumi.String("string"),
	Enable:                 pulumi.Bool(false),
	ReplicationPolicyClass: pulumi.String("string"),
	ConfigPropertiesExcludes: pulumi.StringArray{
		pulumi.String("string"),
	},
	OffsetSyncsTopicLocation:        pulumi.String("string"),
	EmitBackwardHeartbeatsEnabled:   pulumi.Bool(false),
	FollowerFetchingEnabled:         pulumi.Bool(false),
	ExactlyOnceDeliveryEnabled:      pulumi.Bool(false),
	ReplicationFactor:               pulumi.Int(0),
	OffsetLagMax:                    pulumi.Int(0),
	SyncGroupOffsetsEnabled:         pulumi.Bool(false),
	SyncGroupOffsetsIntervalSeconds: pulumi.Int(0),
	EmitHeartbeatsEnabled:           pulumi.Bool(false),
	Timeouts: &aiven.MirrorMakerReplicationFlowTimeoutsArgs{
		Create: pulumi.String("string"),
		Delete: pulumi.String("string"),
		Read:   pulumi.String("string"),
		Update: pulumi.String("string"),
	},
	Topics: pulumi.StringArray{
		pulumi.String("string"),
	},
	TopicsBlacklists: pulumi.StringArray{
		pulumi.String("string"),
	},
})

    resource "aiven_mirror_maker_replication_flow" "mirrorMakerReplicationFlowResource" {
  lifecycle {
    create_before_destroy = true
  }
  source_cluster                      = "string"
  project                             = "string"
  target_cluster                      = "string"
  service_name                        = "string"
  enable                              = false
  replication_policy_class            = "string"
  config_properties_excludes          = ["string"]
  offset_syncs_topic_location         = "string"
  emit_backward_heartbeats_enabled    = false
  follower_fetching_enabled           = false
  exactly_once_delivery_enabled       = false
  replication_factor                  = 0
  offset_lag_max                      = 0
  sync_group_offsets_enabled          = false
  sync_group_offsets_interval_seconds = 0
  emit_heartbeats_enabled             = false
  timeouts = {
    create = "string"
    delete = "string"
    read   = "string"
    update = "string"
  }
  topics            = ["string"]
  topics_blacklists = ["string"]
}

    var mirrorMakerReplicationFlowResource = new MirrorMakerReplicationFlow("mirrorMakerReplicationFlowResource", MirrorMakerReplicationFlowArgs.builder()
    .sourceCluster("string")
    .project("string")
    .targetCluster("string")
    .serviceName("string")
    .enable(false)
    .replicationPolicyClass("string")
    .configPropertiesExcludes("string")
    .offsetSyncsTopicLocation("string")
    .emitBackwardHeartbeatsEnabled(false)
    .followerFetchingEnabled(false)
    .exactlyOnceDeliveryEnabled(false)
    .replicationFactor(0)
    .offsetLagMax(0)
    .syncGroupOffsetsEnabled(false)
    .syncGroupOffsetsIntervalSeconds(0)
    .emitHeartbeatsEnabled(false)
    .timeouts(MirrorMakerReplicationFlowTimeoutsArgs.builder()
        .create("string")
        .delete("string")
        .read("string")
        .update("string")
        .build())
    .topics("string")
    .topicsBlacklists("string")
    .build());

    mirror_maker_replication_flow_resource = aiven.MirrorMakerReplicationFlow("mirrorMakerReplicationFlowResource",
    source_cluster="string",
    project="string",
    target_cluster="string",
    service_name="string",
    enable=False,
    replication_policy_class="string",
    config_properties_excludes=["string"],
    offset_syncs_topic_location="string",
    emit_backward_heartbeats_enabled=False,
    follower_fetching_enabled=False,
    exactly_once_delivery_enabled=False,
    replication_factor=0,
    offset_lag_max=0,
    sync_group_offsets_enabled=False,
    sync_group_offsets_interval_seconds=0,
    emit_heartbeats_enabled=False,
    timeouts={
        "create": "string",
        "delete": "string",
        "read": "string",
        "update": "string",
    },
    topics=["string"],
    topics_blacklists=["string"])

    const mirrorMakerReplicationFlowResource = new aiven.MirrorMakerReplicationFlow("mirrorMakerReplicationFlowResource", {
    sourceCluster: "string",
    project: "string",
    targetCluster: "string",
    serviceName: "string",
    enable: false,
    replicationPolicyClass: "string",
    configPropertiesExcludes: ["string"],
    offsetSyncsTopicLocation: "string",
    emitBackwardHeartbeatsEnabled: false,
    followerFetchingEnabled: false,
    exactlyOnceDeliveryEnabled: false,
    replicationFactor: 0,
    offsetLagMax: 0,
    syncGroupOffsetsEnabled: false,
    syncGroupOffsetsIntervalSeconds: 0,
    emitHeartbeatsEnabled: false,
    timeouts: {
        create: "string",
        "delete": "string",
        read: "string",
        update: "string",
    },
    topics: ["string"],
    topicsBlacklists: ["string"],
});

    type: aiven:MirrorMakerReplicationFlow
properties:
    configPropertiesExcludes:
        - string
    emitBackwardHeartbeatsEnabled: false
    emitHeartbeatsEnabled: false
    enable: false
    exactlyOnceDeliveryEnabled: false
    followerFetchingEnabled: false
    offsetLagMax: 0
    offsetSyncsTopicLocation: string
    project: string
    replicationFactor: 0
    replicationPolicyClass: string
    serviceName: string
    sourceCluster: string
    syncGroupOffsetsEnabled: false
    syncGroupOffsetsIntervalSeconds: 0
    targetCluster: string
    timeouts:
        create: string
        delete: string
        read: string
        update: string
    topics:
        - string
    topicsBlacklists:
        - string

    MirrorMakerReplicationFlow 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 MirrorMakerReplicationFlow resource accepts the following input properties:

    Enable bool
    Is replication flow enabled.
    Project string
    Project name. Changing this property forces recreation of the resource.
    ServiceName string
    Service name. Changing this property forces recreation of the resource.
    SourceCluster string
    The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    TargetCluster string
    The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    ConfigPropertiesExcludes List<string>
    List of topic configuration properties and/or regexes that should not be replicated. If omitted, MirrorMaker will use default list of exclusions. For stability reasons, we always include the unclean.leader.election.enable field in the excluded parameters. If you have specific requirements for this configuration, please reach out to our support team for assistance.
    EmitBackwardHeartbeatsEnabled bool
    Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is false.
    EmitHeartbeatsEnabled bool
    Whether to emit heartbeats to the target cluster. The default value is false.
    ExactlyOnceDeliveryEnabled bool
    Whether to enable exactly-once message delivery. We recommend you set this to enabled for new replications. The default value is false.
    FollowerFetchingEnabled bool
    Assigns a Rack ID based on the availability-zone to enable follower fetching and rack awareness per replication flow.
    OffsetLagMax int
    How out-of-sync a remote partition can be before it is resynced (default: 100).
    OffsetSyncsTopicLocation string
    The location of the offset-syncs topic. The possible values are source and target.
    ReplicationFactor int
    Replication factor used when creating the remote topics. If the replication factor surpasses the number of nodes in the target cluster, topic creation will fail. Minimum value: 1.
    ReplicationPolicyClass string
    Class which defines the remote topic naming convention. The possible values are org.apache.kafka.connect.mirror.DefaultReplicationPolicy and org.apache.kafka.connect.mirror.IdentityReplicationPolicy.
    SyncGroupOffsetsEnabled bool
    Whether to periodically write the translated offsets of replicated consumer groups (in the source cluster) to _consumeroffsets topic in target cluster, as long as no active consumers in that group are connected to the target cluster. The default value is false.
    SyncGroupOffsetsIntervalSeconds int
    Frequency at which consumer group offsets are synced (default: 60, every minute). Minimum value: 1. The default value is 1.
    Timeouts MirrorMakerReplicationFlowTimeouts
    Topics List<string>
    Topic names and regular expressions that match topic names that should be replicated. MirrorMaker will replicate these topics if they are not matched by topicsBlacklist. The topics to include are defined by a list of regular expressions in Java format.
    TopicsBlacklists List<string>
    Topic names and regular expressions that match topic names that should not be replicated. MirrorMaker will not replicate these topics even if they are matched by topics. The topics to exclude are defined by a list of regular expressions in Java format.
    Enable bool
    Is replication flow enabled.
    Project string
    Project name. Changing this property forces recreation of the resource.
    ServiceName string
    Service name. Changing this property forces recreation of the resource.
    SourceCluster string
    The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    TargetCluster string
    The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    ConfigPropertiesExcludes []string
    List of topic configuration properties and/or regexes that should not be replicated. If omitted, MirrorMaker will use default list of exclusions. For stability reasons, we always include the unclean.leader.election.enable field in the excluded parameters. If you have specific requirements for this configuration, please reach out to our support team for assistance.
    EmitBackwardHeartbeatsEnabled bool
    Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is false.
    EmitHeartbeatsEnabled bool
    Whether to emit heartbeats to the target cluster. The default value is false.
    ExactlyOnceDeliveryEnabled bool
    Whether to enable exactly-once message delivery. We recommend you set this to enabled for new replications. The default value is false.
    FollowerFetchingEnabled bool
    Assigns a Rack ID based on the availability-zone to enable follower fetching and rack awareness per replication flow.
    OffsetLagMax int
    How out-of-sync a remote partition can be before it is resynced (default: 100).
    OffsetSyncsTopicLocation string
    The location of the offset-syncs topic. The possible values are source and target.
    ReplicationFactor int
    Replication factor used when creating the remote topics. If the replication factor surpasses the number of nodes in the target cluster, topic creation will fail. Minimum value: 1.
    ReplicationPolicyClass string
    Class which defines the remote topic naming convention. The possible values are org.apache.kafka.connect.mirror.DefaultReplicationPolicy and org.apache.kafka.connect.mirror.IdentityReplicationPolicy.
    SyncGroupOffsetsEnabled bool
    Whether to periodically write the translated offsets of replicated consumer groups (in the source cluster) to _consumeroffsets topic in target cluster, as long as no active consumers in that group are connected to the target cluster. The default value is false.
    SyncGroupOffsetsIntervalSeconds int
    Frequency at which consumer group offsets are synced (default: 60, every minute). Minimum value: 1. The default value is 1.
    Timeouts MirrorMakerReplicationFlowTimeoutsArgs
    Topics []string
    Topic names and regular expressions that match topic names that should be replicated. MirrorMaker will replicate these topics if they are not matched by topicsBlacklist. The topics to include are defined by a list of regular expressions in Java format.
    TopicsBlacklists []string
    Topic names and regular expressions that match topic names that should not be replicated. MirrorMaker will not replicate these topics even if they are matched by topics. The topics to exclude are defined by a list of regular expressions in Java format.
    enable bool
    Is replication flow enabled.
    project string
    Project name. Changing this property forces recreation of the resource.
    service_name string
    Service name. Changing this property forces recreation of the resource.
    source_cluster string
    The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    target_cluster string
    The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    config_properties_excludes list(string)
    List of topic configuration properties and/or regexes that should not be replicated. If omitted, MirrorMaker will use default list of exclusions. For stability reasons, we always include the unclean.leader.election.enable field in the excluded parameters. If you have specific requirements for this configuration, please reach out to our support team for assistance.
    emit_backward_heartbeats_enabled bool
    Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is false.
    emit_heartbeats_enabled bool
    Whether to emit heartbeats to the target cluster. The default value is false.
    exactly_once_delivery_enabled bool
    Whether to enable exactly-once message delivery. We recommend you set this to enabled for new replications. The default value is false.
    follower_fetching_enabled bool
    Assigns a Rack ID based on the availability-zone to enable follower fetching and rack awareness per replication flow.
    offset_lag_max number
    How out-of-sync a remote partition can be before it is resynced (default: 100).
    offset_syncs_topic_location string
    The location of the offset-syncs topic. The possible values are source and target.
    replication_factor number
    Replication factor used when creating the remote topics. If the replication factor surpasses the number of nodes in the target cluster, topic creation will fail. Minimum value: 1.
    replication_policy_class string
    Class which defines the remote topic naming convention. The possible values are org.apache.kafka.connect.mirror.DefaultReplicationPolicy and org.apache.kafka.connect.mirror.IdentityReplicationPolicy.
    sync_group_offsets_enabled bool
    Whether to periodically write the translated offsets of replicated consumer groups (in the source cluster) to _consumeroffsets topic in target cluster, as long as no active consumers in that group are connected to the target cluster. The default value is false.
    sync_group_offsets_interval_seconds number
    Frequency at which consumer group offsets are synced (default: 60, every minute). Minimum value: 1. The default value is 1.
    timeouts object
    topics list(string)
    Topic names and regular expressions that match topic names that should be replicated. MirrorMaker will replicate these topics if they are not matched by topicsBlacklist. The topics to include are defined by a list of regular expressions in Java format.
    topics_blacklists list(string)
    Topic names and regular expressions that match topic names that should not be replicated. MirrorMaker will not replicate these topics even if they are matched by topics. The topics to exclude are defined by a list of regular expressions in Java format.
    enable Boolean
    Is replication flow enabled.
    project String
    Project name. Changing this property forces recreation of the resource.
    serviceName String
    Service name. Changing this property forces recreation of the resource.
    sourceCluster String
    The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    targetCluster String
    The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    configPropertiesExcludes List<String>
    List of topic configuration properties and/or regexes that should not be replicated. If omitted, MirrorMaker will use default list of exclusions. For stability reasons, we always include the unclean.leader.election.enable field in the excluded parameters. If you have specific requirements for this configuration, please reach out to our support team for assistance.
    emitBackwardHeartbeatsEnabled Boolean
    Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is false.
    emitHeartbeatsEnabled Boolean
    Whether to emit heartbeats to the target cluster. The default value is false.
    exactlyOnceDeliveryEnabled Boolean
    Whether to enable exactly-once message delivery. We recommend you set this to enabled for new replications. The default value is false.
    followerFetchingEnabled Boolean
    Assigns a Rack ID based on the availability-zone to enable follower fetching and rack awareness per replication flow.
    offsetLagMax Integer
    How out-of-sync a remote partition can be before it is resynced (default: 100).
    offsetSyncsTopicLocation String
    The location of the offset-syncs topic. The possible values are source and target.
    replicationFactor Integer
    Replication factor used when creating the remote topics. If the replication factor surpasses the number of nodes in the target cluster, topic creation will fail. Minimum value: 1.
    replicationPolicyClass String
    Class which defines the remote topic naming convention. The possible values are org.apache.kafka.connect.mirror.DefaultReplicationPolicy and org.apache.kafka.connect.mirror.IdentityReplicationPolicy.
    syncGroupOffsetsEnabled Boolean
    Whether to periodically write the translated offsets of replicated consumer groups (in the source cluster) to _consumeroffsets topic in target cluster, as long as no active consumers in that group are connected to the target cluster. The default value is false.
    syncGroupOffsetsIntervalSeconds Integer
    Frequency at which consumer group offsets are synced (default: 60, every minute). Minimum value: 1. The default value is 1.
    timeouts MirrorMakerReplicationFlowTimeouts
    topics List<String>
    Topic names and regular expressions that match topic names that should be replicated. MirrorMaker will replicate these topics if they are not matched by topicsBlacklist. The topics to include are defined by a list of regular expressions in Java format.
    topicsBlacklists List<String>
    Topic names and regular expressions that match topic names that should not be replicated. MirrorMaker will not replicate these topics even if they are matched by topics. The topics to exclude are defined by a list of regular expressions in Java format.
    enable boolean
    Is replication flow enabled.
    project string
    Project name. Changing this property forces recreation of the resource.
    serviceName string
    Service name. Changing this property forces recreation of the resource.
    sourceCluster string
    The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    targetCluster string
    The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    configPropertiesExcludes string[]
    List of topic configuration properties and/or regexes that should not be replicated. If omitted, MirrorMaker will use default list of exclusions. For stability reasons, we always include the unclean.leader.election.enable field in the excluded parameters. If you have specific requirements for this configuration, please reach out to our support team for assistance.
    emitBackwardHeartbeatsEnabled boolean
    Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is false.
    emitHeartbeatsEnabled boolean
    Whether to emit heartbeats to the target cluster. The default value is false.
    exactlyOnceDeliveryEnabled boolean
    Whether to enable exactly-once message delivery. We recommend you set this to enabled for new replications. The default value is false.
    followerFetchingEnabled boolean
    Assigns a Rack ID based on the availability-zone to enable follower fetching and rack awareness per replication flow.
    offsetLagMax number
    How out-of-sync a remote partition can be before it is resynced (default: 100).
    offsetSyncsTopicLocation string
    The location of the offset-syncs topic. The possible values are source and target.
    replicationFactor number
    Replication factor used when creating the remote topics. If the replication factor surpasses the number of nodes in the target cluster, topic creation will fail. Minimum value: 1.
    replicationPolicyClass string
    Class which defines the remote topic naming convention. The possible values are org.apache.kafka.connect.mirror.DefaultReplicationPolicy and org.apache.kafka.connect.mirror.IdentityReplicationPolicy.
    syncGroupOffsetsEnabled boolean
    Whether to periodically write the translated offsets of replicated consumer groups (in the source cluster) to _consumeroffsets topic in target cluster, as long as no active consumers in that group are connected to the target cluster. The default value is false.
    syncGroupOffsetsIntervalSeconds number
    Frequency at which consumer group offsets are synced (default: 60, every minute). Minimum value: 1. The default value is 1.
    timeouts MirrorMakerReplicationFlowTimeouts
    topics string[]
    Topic names and regular expressions that match topic names that should be replicated. MirrorMaker will replicate these topics if they are not matched by topicsBlacklist. The topics to include are defined by a list of regular expressions in Java format.
    topicsBlacklists string[]
    Topic names and regular expressions that match topic names that should not be replicated. MirrorMaker will not replicate these topics even if they are matched by topics. The topics to exclude are defined by a list of regular expressions in Java format.
    enable bool
    Is replication flow enabled.
    project str
    Project name. Changing this property forces recreation of the resource.
    service_name str
    Service name. Changing this property forces recreation of the resource.
    source_cluster str
    The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    target_cluster str
    The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    config_properties_excludes Sequence[str]
    List of topic configuration properties and/or regexes that should not be replicated. If omitted, MirrorMaker will use default list of exclusions. For stability reasons, we always include the unclean.leader.election.enable field in the excluded parameters. If you have specific requirements for this configuration, please reach out to our support team for assistance.
    emit_backward_heartbeats_enabled bool
    Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is false.
    emit_heartbeats_enabled bool
    Whether to emit heartbeats to the target cluster. The default value is false.
    exactly_once_delivery_enabled bool
    Whether to enable exactly-once message delivery. We recommend you set this to enabled for new replications. The default value is false.
    follower_fetching_enabled bool
    Assigns a Rack ID based on the availability-zone to enable follower fetching and rack awareness per replication flow.
    offset_lag_max int
    How out-of-sync a remote partition can be before it is resynced (default: 100).
    offset_syncs_topic_location str
    The location of the offset-syncs topic. The possible values are source and target.
    replication_factor int
    Replication factor used when creating the remote topics. If the replication factor surpasses the number of nodes in the target cluster, topic creation will fail. Minimum value: 1.
    replication_policy_class str
    Class which defines the remote topic naming convention. The possible values are org.apache.kafka.connect.mirror.DefaultReplicationPolicy and org.apache.kafka.connect.mirror.IdentityReplicationPolicy.
    sync_group_offsets_enabled bool
    Whether to periodically write the translated offsets of replicated consumer groups (in the source cluster) to _consumeroffsets topic in target cluster, as long as no active consumers in that group are connected to the target cluster. The default value is false.
    sync_group_offsets_interval_seconds int
    Frequency at which consumer group offsets are synced (default: 60, every minute). Minimum value: 1. The default value is 1.
    timeouts MirrorMakerReplicationFlowTimeoutsArgs
    topics Sequence[str]
    Topic names and regular expressions that match topic names that should be replicated. MirrorMaker will replicate these topics if they are not matched by topicsBlacklist. The topics to include are defined by a list of regular expressions in Java format.
    topics_blacklists Sequence[str]
    Topic names and regular expressions that match topic names that should not be replicated. MirrorMaker will not replicate these topics even if they are matched by topics. The topics to exclude are defined by a list of regular expressions in Java format.
    enable Boolean
    Is replication flow enabled.
    project String
    Project name. Changing this property forces recreation of the resource.
    serviceName String
    Service name. Changing this property forces recreation of the resource.
    sourceCluster String
    The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    targetCluster String
    The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    configPropertiesExcludes List<String>
    List of topic configuration properties and/or regexes that should not be replicated. If omitted, MirrorMaker will use default list of exclusions. For stability reasons, we always include the unclean.leader.election.enable field in the excluded parameters. If you have specific requirements for this configuration, please reach out to our support team for assistance.
    emitBackwardHeartbeatsEnabled Boolean
    Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is false.
    emitHeartbeatsEnabled Boolean
    Whether to emit heartbeats to the target cluster. The default value is false.
    exactlyOnceDeliveryEnabled Boolean
    Whether to enable exactly-once message delivery. We recommend you set this to enabled for new replications. The default value is false.
    followerFetchingEnabled Boolean
    Assigns a Rack ID based on the availability-zone to enable follower fetching and rack awareness per replication flow.
    offsetLagMax Number
    How out-of-sync a remote partition can be before it is resynced (default: 100).
    offsetSyncsTopicLocation String
    The location of the offset-syncs topic. The possible values are source and target.
    replicationFactor Number
    Replication factor used when creating the remote topics. If the replication factor surpasses the number of nodes in the target cluster, topic creation will fail. Minimum value: 1.
    replicationPolicyClass String
    Class which defines the remote topic naming convention. The possible values are org.apache.kafka.connect.mirror.DefaultReplicationPolicy and org.apache.kafka.connect.mirror.IdentityReplicationPolicy.
    syncGroupOffsetsEnabled Boolean
    Whether to periodically write the translated offsets of replicated consumer groups (in the source cluster) to _consumeroffsets topic in target cluster, as long as no active consumers in that group are connected to the target cluster. The default value is false.
    syncGroupOffsetsIntervalSeconds Number
    Frequency at which consumer group offsets are synced (default: 60, every minute). Minimum value: 1. The default value is 1.
    timeouts Property Map
    topics List<String>
    Topic names and regular expressions that match topic names that should be replicated. MirrorMaker will replicate these topics if they are not matched by topicsBlacklist. The topics to include are defined by a list of regular expressions in Java format.
    topicsBlacklists List<String>
    Topic names and regular expressions that match topic names that should not be replicated. MirrorMaker will not replicate these topics even if they are matched by topics. The topics to exclude are defined by a list of regular expressions in Java format.

    Outputs

    All input properties are implicitly available as output properties. Additionally, the MirrorMakerReplicationFlow 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 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 MirrorMakerReplicationFlow Resource

    Get an existing MirrorMakerReplicationFlow 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?: MirrorMakerReplicationFlowState, opts?: CustomResourceOptions): MirrorMakerReplicationFlow
    @staticmethod
def get(resource_name: str,
        id: str,
        opts: Optional[ResourceOptions] = None,
        config_properties_excludes: Optional[Sequence[str]] = None,
        emit_backward_heartbeats_enabled: Optional[bool] = None,
        emit_heartbeats_enabled: Optional[bool] = None,
        enable: Optional[bool] = None,
        exactly_once_delivery_enabled: Optional[bool] = None,
        follower_fetching_enabled: Optional[bool] = None,
        offset_lag_max: Optional[int] = None,
        offset_syncs_topic_location: Optional[str] = None,
        project: Optional[str] = None,
        replication_factor: Optional[int] = None,
        replication_policy_class: Optional[str] = None,
        service_name: Optional[str] = None,
        source_cluster: Optional[str] = None,
        sync_group_offsets_enabled: Optional[bool] = None,
        sync_group_offsets_interval_seconds: Optional[int] = None,
        target_cluster: Optional[str] = None,
        timeouts: Optional[MirrorMakerReplicationFlowTimeoutsArgs] = None,
        topics: Optional[Sequence[str]] = None,
        topics_blacklists: Optional[Sequence[str]] = None) -> MirrorMakerReplicationFlow
    func GetMirrorMakerReplicationFlow(ctx *Context, name string, id IDInput, state *MirrorMakerReplicationFlowState, opts ...ResourceOption) (*MirrorMakerReplicationFlow, error)
    public static MirrorMakerReplicationFlow Get(string name, Input<string> id, MirrorMakerReplicationFlowState? state, CustomResourceOptions? opts = null)
    public static MirrorMakerReplicationFlow get(String name, Output<String> id, MirrorMakerReplicationFlowState state, CustomResourceOptions options)
    resources:  _:    type: aiven:MirrorMakerReplicationFlow    get:      id: ${id}
    import {
  to = aiven_mirror_maker_replication_flow.example
  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:
    ConfigPropertiesExcludes List<string>
    List of topic configuration properties and/or regexes that should not be replicated. If omitted, MirrorMaker will use default list of exclusions. For stability reasons, we always include the unclean.leader.election.enable field in the excluded parameters. If you have specific requirements for this configuration, please reach out to our support team for assistance.
    EmitBackwardHeartbeatsEnabled bool
    Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is false.
    EmitHeartbeatsEnabled bool
    Whether to emit heartbeats to the target cluster. The default value is false.
    Enable bool
    Is replication flow enabled.
    ExactlyOnceDeliveryEnabled bool
    Whether to enable exactly-once message delivery. We recommend you set this to enabled for new replications. The default value is false.
    FollowerFetchingEnabled bool
    Assigns a Rack ID based on the availability-zone to enable follower fetching and rack awareness per replication flow.
    OffsetLagMax int
    How out-of-sync a remote partition can be before it is resynced (default: 100).
    OffsetSyncsTopicLocation string
    The location of the offset-syncs topic. The possible values are source and target.
    Project string
    Project name. Changing this property forces recreation of the resource.
    ReplicationFactor int
    Replication factor used when creating the remote topics. If the replication factor surpasses the number of nodes in the target cluster, topic creation will fail. Minimum value: 1.
    ReplicationPolicyClass string
    Class which defines the remote topic naming convention. The possible values are org.apache.kafka.connect.mirror.DefaultReplicationPolicy and org.apache.kafka.connect.mirror.IdentityReplicationPolicy.
    ServiceName string
    Service name. Changing this property forces recreation of the resource.
    SourceCluster string
    The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    SyncGroupOffsetsEnabled bool
    Whether to periodically write the translated offsets of replicated consumer groups (in the source cluster) to _consumeroffsets topic in target cluster, as long as no active consumers in that group are connected to the target cluster. The default value is false.
    SyncGroupOffsetsIntervalSeconds int
    Frequency at which consumer group offsets are synced (default: 60, every minute). Minimum value: 1. The default value is 1.
    TargetCluster string
    The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    Timeouts MirrorMakerReplicationFlowTimeouts
    Topics List<string>
    Topic names and regular expressions that match topic names that should be replicated. MirrorMaker will replicate these topics if they are not matched by topicsBlacklist. The topics to include are defined by a list of regular expressions in Java format.
    TopicsBlacklists List<string>
    Topic names and regular expressions that match topic names that should not be replicated. MirrorMaker will not replicate these topics even if they are matched by topics. The topics to exclude are defined by a list of regular expressions in Java format.
    ConfigPropertiesExcludes []string
    List of topic configuration properties and/or regexes that should not be replicated. If omitted, MirrorMaker will use default list of exclusions. For stability reasons, we always include the unclean.leader.election.enable field in the excluded parameters. If you have specific requirements for this configuration, please reach out to our support team for assistance.
    EmitBackwardHeartbeatsEnabled bool
    Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is false.
    EmitHeartbeatsEnabled bool
    Whether to emit heartbeats to the target cluster. The default value is false.
    Enable bool
    Is replication flow enabled.
    ExactlyOnceDeliveryEnabled bool
    Whether to enable exactly-once message delivery. We recommend you set this to enabled for new replications. The default value is false.
    FollowerFetchingEnabled bool
    Assigns a Rack ID based on the availability-zone to enable follower fetching and rack awareness per replication flow.
    OffsetLagMax int
    How out-of-sync a remote partition can be before it is resynced (default: 100).
    OffsetSyncsTopicLocation string
    The location of the offset-syncs topic. The possible values are source and target.
    Project string
    Project name. Changing this property forces recreation of the resource.
    ReplicationFactor int
    Replication factor used when creating the remote topics. If the replication factor surpasses the number of nodes in the target cluster, topic creation will fail. Minimum value: 1.
    ReplicationPolicyClass string
    Class which defines the remote topic naming convention. The possible values are org.apache.kafka.connect.mirror.DefaultReplicationPolicy and org.apache.kafka.connect.mirror.IdentityReplicationPolicy.
    ServiceName string
    Service name. Changing this property forces recreation of the resource.
    SourceCluster string
    The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    SyncGroupOffsetsEnabled bool
    Whether to periodically write the translated offsets of replicated consumer groups (in the source cluster) to _consumeroffsets topic in target cluster, as long as no active consumers in that group are connected to the target cluster. The default value is false.
    SyncGroupOffsetsIntervalSeconds int
    Frequency at which consumer group offsets are synced (default: 60, every minute). Minimum value: 1. The default value is 1.
    TargetCluster string
    The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    Timeouts MirrorMakerReplicationFlowTimeoutsArgs
    Topics []string
    Topic names and regular expressions that match topic names that should be replicated. MirrorMaker will replicate these topics if they are not matched by topicsBlacklist. The topics to include are defined by a list of regular expressions in Java format.
    TopicsBlacklists []string
    Topic names and regular expressions that match topic names that should not be replicated. MirrorMaker will not replicate these topics even if they are matched by topics. The topics to exclude are defined by a list of regular expressions in Java format.
    config_properties_excludes list(string)
    List of topic configuration properties and/or regexes that should not be replicated. If omitted, MirrorMaker will use default list of exclusions. For stability reasons, we always include the unclean.leader.election.enable field in the excluded parameters. If you have specific requirements for this configuration, please reach out to our support team for assistance.
    emit_backward_heartbeats_enabled bool
    Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is false.
    emit_heartbeats_enabled bool
    Whether to emit heartbeats to the target cluster. The default value is false.
    enable bool
    Is replication flow enabled.
    exactly_once_delivery_enabled bool
    Whether to enable exactly-once message delivery. We recommend you set this to enabled for new replications. The default value is false.
    follower_fetching_enabled bool
    Assigns a Rack ID based on the availability-zone to enable follower fetching and rack awareness per replication flow.
    offset_lag_max number
    How out-of-sync a remote partition can be before it is resynced (default: 100).
    offset_syncs_topic_location string
    The location of the offset-syncs topic. The possible values are source and target.
    project string
    Project name. Changing this property forces recreation of the resource.
    replication_factor number
    Replication factor used when creating the remote topics. If the replication factor surpasses the number of nodes in the target cluster, topic creation will fail. Minimum value: 1.
    replication_policy_class string
    Class which defines the remote topic naming convention. The possible values are org.apache.kafka.connect.mirror.DefaultReplicationPolicy and org.apache.kafka.connect.mirror.IdentityReplicationPolicy.
    service_name string
    Service name. Changing this property forces recreation of the resource.
    source_cluster string
    The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    sync_group_offsets_enabled bool
    Whether to periodically write the translated offsets of replicated consumer groups (in the source cluster) to _consumeroffsets topic in target cluster, as long as no active consumers in that group are connected to the target cluster. The default value is false.
    sync_group_offsets_interval_seconds number
    Frequency at which consumer group offsets are synced (default: 60, every minute). Minimum value: 1. The default value is 1.
    target_cluster string
    The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    timeouts object
    topics list(string)
    Topic names and regular expressions that match topic names that should be replicated. MirrorMaker will replicate these topics if they are not matched by topicsBlacklist. The topics to include are defined by a list of regular expressions in Java format.
    topics_blacklists list(string)
    Topic names and regular expressions that match topic names that should not be replicated. MirrorMaker will not replicate these topics even if they are matched by topics. The topics to exclude are defined by a list of regular expressions in Java format.
    configPropertiesExcludes List<String>
    List of topic configuration properties and/or regexes that should not be replicated. If omitted, MirrorMaker will use default list of exclusions. For stability reasons, we always include the unclean.leader.election.enable field in the excluded parameters. If you have specific requirements for this configuration, please reach out to our support team for assistance.
    emitBackwardHeartbeatsEnabled Boolean
    Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is false.
    emitHeartbeatsEnabled Boolean
    Whether to emit heartbeats to the target cluster. The default value is false.
    enable Boolean
    Is replication flow enabled.
    exactlyOnceDeliveryEnabled Boolean
    Whether to enable exactly-once message delivery. We recommend you set this to enabled for new replications. The default value is false.
    followerFetchingEnabled Boolean
    Assigns a Rack ID based on the availability-zone to enable follower fetching and rack awareness per replication flow.
    offsetLagMax Integer
    How out-of-sync a remote partition can be before it is resynced (default: 100).
    offsetSyncsTopicLocation String
    The location of the offset-syncs topic. The possible values are source and target.
    project String
    Project name. Changing this property forces recreation of the resource.
    replicationFactor Integer
    Replication factor used when creating the remote topics. If the replication factor surpasses the number of nodes in the target cluster, topic creation will fail. Minimum value: 1.
    replicationPolicyClass String
    Class which defines the remote topic naming convention. The possible values are org.apache.kafka.connect.mirror.DefaultReplicationPolicy and org.apache.kafka.connect.mirror.IdentityReplicationPolicy.
    serviceName String
    Service name. Changing this property forces recreation of the resource.
    sourceCluster String
    The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    syncGroupOffsetsEnabled Boolean
    Whether to periodically write the translated offsets of replicated consumer groups (in the source cluster) to _consumeroffsets topic in target cluster, as long as no active consumers in that group are connected to the target cluster. The default value is false.
    syncGroupOffsetsIntervalSeconds Integer
    Frequency at which consumer group offsets are synced (default: 60, every minute). Minimum value: 1. The default value is 1.
    targetCluster String
    The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    timeouts MirrorMakerReplicationFlowTimeouts
    topics List<String>
    Topic names and regular expressions that match topic names that should be replicated. MirrorMaker will replicate these topics if they are not matched by topicsBlacklist. The topics to include are defined by a list of regular expressions in Java format.
    topicsBlacklists List<String>
    Topic names and regular expressions that match topic names that should not be replicated. MirrorMaker will not replicate these topics even if they are matched by topics. The topics to exclude are defined by a list of regular expressions in Java format.
    configPropertiesExcludes string[]
    List of topic configuration properties and/or regexes that should not be replicated. If omitted, MirrorMaker will use default list of exclusions. For stability reasons, we always include the unclean.leader.election.enable field in the excluded parameters. If you have specific requirements for this configuration, please reach out to our support team for assistance.
    emitBackwardHeartbeatsEnabled boolean
    Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is false.
    emitHeartbeatsEnabled boolean
    Whether to emit heartbeats to the target cluster. The default value is false.
    enable boolean
    Is replication flow enabled.
    exactlyOnceDeliveryEnabled boolean
    Whether to enable exactly-once message delivery. We recommend you set this to enabled for new replications. The default value is false.
    followerFetchingEnabled boolean
    Assigns a Rack ID based on the availability-zone to enable follower fetching and rack awareness per replication flow.
    offsetLagMax number
    How out-of-sync a remote partition can be before it is resynced (default: 100).
    offsetSyncsTopicLocation string
    The location of the offset-syncs topic. The possible values are source and target.
    project string
    Project name. Changing this property forces recreation of the resource.
    replicationFactor number
    Replication factor used when creating the remote topics. If the replication factor surpasses the number of nodes in the target cluster, topic creation will fail. Minimum value: 1.
    replicationPolicyClass string
    Class which defines the remote topic naming convention. The possible values are org.apache.kafka.connect.mirror.DefaultReplicationPolicy and org.apache.kafka.connect.mirror.IdentityReplicationPolicy.
    serviceName string
    Service name. Changing this property forces recreation of the resource.
    sourceCluster string
    The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    syncGroupOffsetsEnabled boolean
    Whether to periodically write the translated offsets of replicated consumer groups (in the source cluster) to _consumeroffsets topic in target cluster, as long as no active consumers in that group are connected to the target cluster. The default value is false.
    syncGroupOffsetsIntervalSeconds number
    Frequency at which consumer group offsets are synced (default: 60, every minute). Minimum value: 1. The default value is 1.
    targetCluster string
    The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    timeouts MirrorMakerReplicationFlowTimeouts
    topics string[]
    Topic names and regular expressions that match topic names that should be replicated. MirrorMaker will replicate these topics if they are not matched by topicsBlacklist. The topics to include are defined by a list of regular expressions in Java format.
    topicsBlacklists string[]
    Topic names and regular expressions that match topic names that should not be replicated. MirrorMaker will not replicate these topics even if they are matched by topics. The topics to exclude are defined by a list of regular expressions in Java format.
    config_properties_excludes Sequence[str]
    List of topic configuration properties and/or regexes that should not be replicated. If omitted, MirrorMaker will use default list of exclusions. For stability reasons, we always include the unclean.leader.election.enable field in the excluded parameters. If you have specific requirements for this configuration, please reach out to our support team for assistance.
    emit_backward_heartbeats_enabled bool
    Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is false.
    emit_heartbeats_enabled bool
    Whether to emit heartbeats to the target cluster. The default value is false.
    enable bool
    Is replication flow enabled.
    exactly_once_delivery_enabled bool
    Whether to enable exactly-once message delivery. We recommend you set this to enabled for new replications. The default value is false.
    follower_fetching_enabled bool
    Assigns a Rack ID based on the availability-zone to enable follower fetching and rack awareness per replication flow.
    offset_lag_max int
    How out-of-sync a remote partition can be before it is resynced (default: 100).
    offset_syncs_topic_location str
    The location of the offset-syncs topic. The possible values are source and target.
    project str
    Project name. Changing this property forces recreation of the resource.
    replication_factor int
    Replication factor used when creating the remote topics. If the replication factor surpasses the number of nodes in the target cluster, topic creation will fail. Minimum value: 1.
    replication_policy_class str
    Class which defines the remote topic naming convention. The possible values are org.apache.kafka.connect.mirror.DefaultReplicationPolicy and org.apache.kafka.connect.mirror.IdentityReplicationPolicy.
    service_name str
    Service name. Changing this property forces recreation of the resource.
    source_cluster str
    The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    sync_group_offsets_enabled bool
    Whether to periodically write the translated offsets of replicated consumer groups (in the source cluster) to _consumeroffsets topic in target cluster, as long as no active consumers in that group are connected to the target cluster. The default value is false.
    sync_group_offsets_interval_seconds int
    Frequency at which consumer group offsets are synced (default: 60, every minute). Minimum value: 1. The default value is 1.
    target_cluster str
    The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    timeouts MirrorMakerReplicationFlowTimeoutsArgs
    topics Sequence[str]
    Topic names and regular expressions that match topic names that should be replicated. MirrorMaker will replicate these topics if they are not matched by topicsBlacklist. The topics to include are defined by a list of regular expressions in Java format.
    topics_blacklists Sequence[str]
    Topic names and regular expressions that match topic names that should not be replicated. MirrorMaker will not replicate these topics even if they are matched by topics. The topics to exclude are defined by a list of regular expressions in Java format.
    configPropertiesExcludes List<String>
    List of topic configuration properties and/or regexes that should not be replicated. If omitted, MirrorMaker will use default list of exclusions. For stability reasons, we always include the unclean.leader.election.enable field in the excluded parameters. If you have specific requirements for this configuration, please reach out to our support team for assistance.
    emitBackwardHeartbeatsEnabled Boolean
    Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is false.
    emitHeartbeatsEnabled Boolean
    Whether to emit heartbeats to the target cluster. The default value is false.
    enable Boolean
    Is replication flow enabled.
    exactlyOnceDeliveryEnabled Boolean
    Whether to enable exactly-once message delivery. We recommend you set this to enabled for new replications. The default value is false.
    followerFetchingEnabled Boolean
    Assigns a Rack ID based on the availability-zone to enable follower fetching and rack awareness per replication flow.
    offsetLagMax Number
    How out-of-sync a remote partition can be before it is resynced (default: 100).
    offsetSyncsTopicLocation String
    The location of the offset-syncs topic. The possible values are source and target.
    project String
    Project name. Changing this property forces recreation of the resource.
    replicationFactor Number
    Replication factor used when creating the remote topics. If the replication factor surpasses the number of nodes in the target cluster, topic creation will fail. Minimum value: 1.
    replicationPolicyClass String
    Class which defines the remote topic naming convention. The possible values are org.apache.kafka.connect.mirror.DefaultReplicationPolicy and org.apache.kafka.connect.mirror.IdentityReplicationPolicy.
    serviceName String
    Service name. Changing this property forces recreation of the resource.
    sourceCluster String
    The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    syncGroupOffsetsEnabled Boolean
    Whether to periodically write the translated offsets of replicated consumer groups (in the source cluster) to _consumeroffsets topic in target cluster, as long as no active consumers in that group are connected to the target cluster. The default value is false.
    syncGroupOffsetsIntervalSeconds Number
    Frequency at which consumer group offsets are synced (default: 60, every minute). Minimum value: 1. The default value is 1.
    targetCluster String
    The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -. Maximum length: 128. Changing this property forces recreation of the resource.
    timeouts Property Map
    topics List<String>
    Topic names and regular expressions that match topic names that should be replicated. MirrorMaker will replicate these topics if they are not matched by topicsBlacklist. The topics to include are defined by a list of regular expressions in Java format.
    topicsBlacklists List<String>
    Topic names and regular expressions that match topic names that should not be replicated. MirrorMaker will not replicate these topics even if they are matched by topics. The topics to exclude are defined by a list of regular expressions in Java format.

    Supporting Types

    MirrorMakerReplicationFlowTimeouts, MirrorMakerReplicationFlowTimeoutsArgs

    Create string
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
    Default string
    Timeout for all operations. Deprecated, use operation-specific timeouts instead.

    Deprecated: Use operation-specific timeouts instead. This field will be removed in the next major version.

    Delete string
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs.
    Read string
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Read operations occur during any refresh or planning operation when refresh is enabled.
    Update string
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
    Create string
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
    Default string
    Timeout for all operations. Deprecated, use operation-specific timeouts instead.

    Deprecated: Use operation-specific timeouts instead. This field will be removed in the next major version.

    Delete string
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs.
    Read string
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Read operations occur during any refresh or planning operation when refresh is enabled.
    Update string
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
    create string
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
    default string
    Timeout for all operations. Deprecated, use operation-specific timeouts instead.

    Deprecated: Use operation-specific timeouts instead. This field will be removed in the next major version.

    delete string
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs.
    read string
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Read operations occur during any refresh or planning operation when refresh is enabled.
    update string
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
    create String
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
    default_ String
    Timeout for all operations. Deprecated, use operation-specific timeouts instead.

    Deprecated: Use operation-specific timeouts instead. This field will be removed in the next major version.

    delete String
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs.
    read String
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Read operations occur during any refresh or planning operation when refresh is enabled.
    update String
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
    create string
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
    default string
    Timeout for all operations. Deprecated, use operation-specific timeouts instead.

    Deprecated: Use operation-specific timeouts instead. This field will be removed in the next major version.

    delete string
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs.
    read string
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Read operations occur during any refresh or planning operation when refresh is enabled.
    update string
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
    create str
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
    default str
    Timeout for all operations. Deprecated, use operation-specific timeouts instead.

    Deprecated: Use operation-specific timeouts instead. This field will be removed in the next major version.

    delete str
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs.
    read str
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Read operations occur during any refresh or planning operation when refresh is enabled.
    update str
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
    create String
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
    default String
    Timeout for all operations. Deprecated, use operation-specific timeouts instead.

    Deprecated: Use operation-specific timeouts instead. This field will be removed in the next major version.

    delete String
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs.
    read String
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Read operations occur during any refresh or planning operation when refresh is enabled.
    update String
    A string that can be parsed as a duration consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).

    Import

    $ pulumi import aiven:index/mirrorMakerReplicationFlow:MirrorMakerReplicationFlow example PROJECT/SERVICE_NAME/SOURCE_CLUSTER/TARGET_CLUSTER

    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 aiven logo
    Viewing docs for Aiven v6.59.0
    published on Thursday, Sep 17, 2026 by Pulumi
    Schema (JSON)
    pulumi/pulumi-aiven

      Try Pulumi Cloud free.
      Your team will thank you.

      Start free trial