Ready to level-up your engineering skills? Join a Pulumi Workshop. Register Now
  1. Docs
  2. Reference
  3. API
  4. Aiven
  5. getMirrorMakerReplicationFlow

getMirrorMakerReplicationFlow

# MirrorMaker 2 Replication Flow Data Source

The MirrorMaker 2 Replication Flow data source provides information about the existing MirrorMaker 2 Replication Flow on Aiven Cloud.

Example Usage

using Pulumi;
using Aiven = Pulumi.Aiven;

class MyStack : Stack
{
    public MyStack()
    {
        var f1 = Output.Create(Aiven.GetMirrorMakerReplicationFlow.InvokeAsync(new Aiven.GetMirrorMakerReplicationFlowArgs
        {
            Project = aiven_project.Kafka_mm_project1.Project,
            ServiceName = aiven_service.Mm.Service_name,
            SourceCluster = aiven_service.Source.Service_name,
            TargetCluster = aiven_service.Target.Service_name,
        }));
    }

}

package main

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

func main() {
    pulumi.Run(func(ctx *pulumi.Context) error {
        _, err := aiven.LookupMirrorMakerReplicationFlow(ctx, &aiven.LookupMirrorMakerReplicationFlowArgs{
            Project:       aiven_project.Kafka - mm - project1.Project,
            ServiceName:   aiven_service.Mm.Service_name,
            SourceCluster: aiven_service.Source.Service_name,
            TargetCluster: aiven_service.Target.Service_name,
        }, nil)
        if err != nil {
            return err
        }
        return nil
    })
}
import pulumi
import pulumi_aiven as aiven

f1 = aiven.get_mirror_maker_replication_flow(project=aiven_project["kafka-mm-project1"]["project"],
    service_name=aiven_service["mm"]["service_name"],
    source_cluster=aiven_service["source"]["service_name"],
    target_cluster=aiven_service["target"]["service_name"])
import * as pulumi from "@pulumi/pulumi";
import * as aiven from "@pulumi/aiven";

const f1 = aiven.getMirrorMakerReplicationFlow({
    project: aiven_project["kafka-mm-project1"].project,
    serviceName: aiven_service.mm.service_name,
    sourceCluster: aiven_service.source.service_name,
    targetCluster: aiven_service.target.service_name,
});

Using getMirrorMakerReplicationFlow

function getMirrorMakerReplicationFlow(args: GetMirrorMakerReplicationFlowArgs, opts?: InvokeOptions): Promise<GetMirrorMakerReplicationFlowResult>
def get_mirror_maker_replication_flow(enable: Optional[bool] = None, project: Optional[str] = None, service_name: Optional[str] = None, source_cluster: Optional[str] = None, target_cluster: Optional[str] = None, topics: Optional[Sequence[str]] = None, topics_blacklists: Optional[Sequence[str]] = None, opts: Optional[InvokeOptions] = None) -> GetMirrorMakerReplicationFlowResult
func LookupMirrorMakerReplicationFlow(ctx *Context, args *LookupMirrorMakerReplicationFlowArgs, opts ...InvokeOption) (*LookupMirrorMakerReplicationFlowResult, error)

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

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

The following arguments are supported:

Project string

and service_name - (Required) define the project and service the Kafka MirrorMaker Replication Flow belongs to. They should be defined using reference as shown above to set up dependencies correctly.

ServiceName string
SourceCluster string

is a source cluster alias.

TargetCluster string

is a target cluster alias.

Enable bool

enable of disable replication flows for a MirrorMaker service

Topics List<string>

is a list of topics and/or regular expressions to replicate.

TopicsBlacklists List<string>

is a list of topics and/or regular expressions to not replicate.

Project string

and service_name - (Required) define the project and service the Kafka MirrorMaker Replication Flow belongs to. They should be defined using reference as shown above to set up dependencies correctly.

ServiceName string
SourceCluster string

is a source cluster alias.

TargetCluster string

is a target cluster alias.

Enable bool

enable of disable replication flows for a MirrorMaker service

Topics []string

is a list of topics and/or regular expressions to replicate.

TopicsBlacklists []string

is a list of topics and/or regular expressions to not replicate.

project string

and service_name - (Required) define the project and service the Kafka MirrorMaker Replication Flow belongs to. They should be defined using reference as shown above to set up dependencies correctly.

serviceName string
sourceCluster string

is a source cluster alias.

targetCluster string

is a target cluster alias.

enable boolean

enable of disable replication flows for a MirrorMaker service

topics string[]

is a list of topics and/or regular expressions to replicate.

topicsBlacklists string[]

is a list of topics and/or regular expressions to not replicate.

project str

and service_name - (Required) define the project and service the Kafka MirrorMaker Replication Flow belongs to. They should be defined using reference as shown above to set up dependencies correctly.

service_name str
source_cluster str

is a source cluster alias.

target_cluster str

is a target cluster alias.

enable bool

enable of disable replication flows for a MirrorMaker service

topics Sequence[str]

is a list of topics and/or regular expressions to replicate.

topics_blacklists Sequence[str]

is a list of topics and/or regular expressions to not replicate.

getMirrorMakerReplicationFlow Result

The following output properties are available:

Id string

The provider-assigned unique ID for this managed resource.

Project string
ServiceName string
SourceCluster string
TargetCluster string
Enable bool

enable of disable replication flows for a MirrorMaker service

Topics List<string>

is a list of topics and/or regular expressions to replicate.

TopicsBlacklists List<string>

is a list of topics and/or regular expressions to not replicate.

Id string

The provider-assigned unique ID for this managed resource.

Project string
ServiceName string
SourceCluster string
TargetCluster string
Enable bool

enable of disable replication flows for a MirrorMaker service

Topics []string

is a list of topics and/or regular expressions to replicate.

TopicsBlacklists []string

is a list of topics and/or regular expressions to not replicate.

id string

The provider-assigned unique ID for this managed resource.

project string
serviceName string
sourceCluster string
targetCluster string
enable boolean

enable of disable replication flows for a MirrorMaker service

topics string[]

is a list of topics and/or regular expressions to replicate.

topicsBlacklists string[]

is a list of topics and/or regular expressions to not replicate.

id str

The provider-assigned unique ID for this managed resource.

project str
service_name str
source_cluster str
target_cluster str
enable bool

enable of disable replication flows for a MirrorMaker service

topics Sequence[str]

is a list of topics and/or regular expressions to replicate.

topics_blacklists Sequence[str]

is a list of topics and/or regular expressions to not replicate.

Package Details

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