aiven.getMirrorMakerReplicationFlow

Aiven v6.60.0, Sep 23 26

Viewing docs for Aiven v6.60.0
published on Wednesday, Sep 23, 2026 by Pulumi

Schema (JSON)

pulumi/pulumi-aiven

Viewing docs for Aiven v6.60.0
published on Wednesday, Sep 23, 2026 by Pulumi

Schema (JSON)

pulumi/pulumi-aiven

Example Usage

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

const example = aiven.getMirrorMakerReplicationFlow({
    project: "my-project",
    serviceName: "foo",
    sourceCluster: "kafka-abc",
    targetCluster: "kafka-abc",
});

import pulumi
import pulumi_aiven as aiven

example = aiven.get_mirror_maker_replication_flow(project="my-project",
    service_name="foo",
    source_cluster="kafka-abc",
    target_cluster="kafka-abc")

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.GetMirrorMakerReplicationFlow(ctx, &aiven.LookupMirrorMakerReplicationFlowArgs{
			Project:       "my-project",
			ServiceName:   "foo",
			SourceCluster: "kafka-abc",
			TargetCluster: "kafka-abc",
		}, nil)
		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 = Aiven.GetMirrorMakerReplicationFlow.Invoke(new()
    {
        Project = "my-project",
        ServiceName = "foo",
        SourceCluster = "kafka-abc",
        TargetCluster = "kafka-abc",
    });

});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aiven.AivenFunctions;
import com.pulumi.aiven.inputs.GetMirrorMakerReplicationFlowArgs;
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) {
        final var example = AivenFunctions.getMirrorMakerReplicationFlow(GetMirrorMakerReplicationFlowArgs.builder()
            .project("my-project")
            .serviceName("foo")
            .sourceCluster("kafka-abc")
            .targetCluster("kafka-abc")
            .build());

    }
}

variables:
  example:
    fn::invoke:
      function: aiven:getMirrorMakerReplicationFlow
      arguments:
        project: my-project
        serviceName: foo
        sourceCluster: kafka-abc
        targetCluster: kafka-abc

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

data "aiven_getmirrormakerreplicationflow" "example" {
  project        = "my-project"
  service_name   = "foo"
  source_cluster = "kafka-abc"
  target_cluster = "kafka-abc"
}

Using getMirrorMakerReplicationFlow

Two invocation forms are available. The direct form accepts plain arguments and either blocks until the result value is available, or returns a Promise-wrapped result. The output form accepts Input-wrapped arguments and returns an Output-wrapped result.

function getMirrorMakerReplicationFlow(args: GetMirrorMakerReplicationFlowArgs, opts?: InvokeOptions): Promise<GetMirrorMakerReplicationFlowResult>
function getMirrorMakerReplicationFlowOutput(args: GetMirrorMakerReplicationFlowOutputArgs, opts?: InvokeOutputOptions): Output<GetMirrorMakerReplicationFlowResult>

def get_mirror_maker_replication_flow(project: Optional[str] = None,
                                      service_name: Optional[str] = None,
                                      source_cluster: Optional[str] = None,
                                      target_cluster: Optional[str] = None,
                                      timeouts: Optional[GetMirrorMakerReplicationFlowTimeouts] = None,
                                      opts: Optional[InvokeOptions] = None) -> GetMirrorMakerReplicationFlowResult
def get_mirror_maker_replication_flow_output(project: pulumi.Input[Optional[str]] = None,
                                      service_name: pulumi.Input[Optional[str]] = None,
                                      source_cluster: pulumi.Input[Optional[str]] = None,
                                      target_cluster: pulumi.Input[Optional[str]] = None,
                                      timeouts: pulumi.Input[Optional[GetMirrorMakerReplicationFlowTimeoutsArgs]] = None,
                                      opts: Optional[InvokeOutputOptions] = None) -> Output[GetMirrorMakerReplicationFlowResult]

func LookupMirrorMakerReplicationFlow(ctx *Context, args *LookupMirrorMakerReplicationFlowArgs, opts ...InvokeOption) (*LookupMirrorMakerReplicationFlowResult, error)
func LookupMirrorMakerReplicationFlowOutput(ctx *Context, args *LookupMirrorMakerReplicationFlowOutputArgs, opts ...InvokeOption) LookupMirrorMakerReplicationFlowResultOutput

> Note: This function is named LookupMirrorMakerReplicationFlow in the Go SDK.

public static class GetMirrorMakerReplicationFlow 
{
    public static Task<GetMirrorMakerReplicationFlowResult> InvokeAsync(GetMirrorMakerReplicationFlowArgs args, InvokeOptions? opts = null)
    public static Output<GetMirrorMakerReplicationFlowResult> Invoke(GetMirrorMakerReplicationFlowInvokeArgs args, InvokeOptions? opts = null)
    public static Output<GetMirrorMakerReplicationFlowResult> Invoke(GetMirrorMakerReplicationFlowInvokeArgs args, InvokeOutputOptions opts)
}

public static CompletableFuture<GetMirrorMakerReplicationFlowResult> getMirrorMakerReplicationFlow(GetMirrorMakerReplicationFlowArgs args, InvokeOptions options)
public static Output<GetMirrorMakerReplicationFlowResult> getMirrorMakerReplicationFlow(GetMirrorMakerReplicationFlowArgs args, InvokeOptions options)
public static Output<GetMirrorMakerReplicationFlowResult> getMirrorMakerReplicationFlow(GetMirrorMakerReplicationFlowArgs args, InvokeOutputOptions options)

fn::invoke:
  function: aiven:index/getMirrorMakerReplicationFlow:getMirrorMakerReplicationFlow
  arguments:
    # arguments dictionary

data "aiven_get_mirror_maker_replication_flow" "name" {
    # arguments
}

The following arguments are supported:

Project string: Project name.
ServiceName string: Service name.
SourceCluster string: The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
TargetCluster string: The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
Timeouts GetMirrorMakerReplicationFlowTimeouts

Project string: Project name.
ServiceName string: Service name.
SourceCluster string: The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
TargetCluster string: The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
Timeouts GetMirrorMakerReplicationFlowTimeouts

project string: Project name.
service_name string: Service name.
source_cluster string: The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
target_cluster string: The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
timeouts object

project String: Project name.
serviceName String: Service name.
sourceCluster String: The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
targetCluster String: The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
timeouts GetMirrorMakerReplicationFlowTimeouts

project string: Project name.
serviceName string: Service name.
sourceCluster string: The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
targetCluster string: The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
timeouts GetMirrorMakerReplicationFlowTimeouts

project str: Project name.
service_name str: Service name.
source_cluster str: The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
target_cluster str: The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
timeouts GetMirrorMakerReplicationFlowTimeouts

project String: Project name.
serviceName String: Service name.
sourceCluster String: The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
targetCluster String: The alias of the target cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
timeouts Property Map

getMirrorMakerReplicationFlow Result

The following output properties are available:

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.
Id string: Resource ID composed as: project/service_name/source_cluster/target_cluster.
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.
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.
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.
SourceCluster string: The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
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). 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 -.
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.
Timeouts GetMirrorMakerReplicationFlowTimeouts

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.
Id string: Resource ID composed as: project/service_name/source_cluster/target_cluster.
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.
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.
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.
SourceCluster string: The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
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). 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 -.
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.
Timeouts GetMirrorMakerReplicationFlowTimeouts

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.
id string: Resource ID composed as: project/service_name/source_cluster/target_cluster.
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.
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.
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.
source_cluster string: The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
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). 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 -.
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.
timeouts object

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.
id String: Resource ID composed as: project/service_name/source_cluster/target_cluster.
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.
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.
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.
sourceCluster String: The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
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). 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 -.
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.
timeouts GetMirrorMakerReplicationFlowTimeouts

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.
id string: Resource ID composed as: project/service_name/source_cluster/target_cluster.
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.
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.
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.
sourceCluster string: The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
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). 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 -.
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.
timeouts GetMirrorMakerReplicationFlowTimeouts

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.
id str: Resource ID composed as: project/service_name/source_cluster/target_cluster.
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.
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.
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.
source_cluster str: The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
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). 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 -.
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.
timeouts GetMirrorMakerReplicationFlowTimeouts

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.
id String: Resource ID composed as: project/service_name/source_cluster/target_cluster.
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.
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.
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.
sourceCluster String: The alias of the source cluster to use in this replication flow. Can contain the following symbols: ASCII alphanumerics, ., _, and -.
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). 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 -.
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.
timeouts Property Map

Supporting Types

GetMirrorMakerReplicationFlowTimeouts

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 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 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 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 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 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 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).

Package Details

Repository: Aiven pulumi/pulumi-aiven
License: Apache-2.0
Notes: This Pulumi package is based on the aiven Terraform Provider.

Viewing docs for Aiven v6.60.0
published on Wednesday, Sep 23, 2026 by Pulumi

Schema (JSON)

pulumi/pulumi-aiven

aiven.getMirrorMakerReplicationFlow

On this page

On this page

Example Usage

Using getMirrorMakerReplicationFlow

getMirrorMakerReplicationFlow Result

Supporting Types

GetMirrorMakerReplicationFlowTimeouts

Package Details

On this page

On this page

Try Pulumi Cloud free.
Your team will thank you.

aiven.getMirrorMakerReplicationFlow

On this page

On this page

Example Usage

Using getMirrorMakerReplicationFlow

getMirrorMakerReplicationFlow Result

Supporting Types

GetMirrorMakerReplicationFlowTimeouts

Package Details

On this page

On this page

Try Pulumi Cloud free.Your team will thank you.

Try Pulumi Cloud free.
Your team will thank you.