Replicator

import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";
const test = new aws.msk.Replicator("test", {
    replicatorName: "test-name",
    description: "test-description",
    serviceExecutionRoleArn: sourceAwsIamRole.arn,
    kafkaClusters: [
        {
            amazonMskCluster: {
                mskClusterArn: source.arn,
            },
            vpcConfig: {
                subnetIds: sourceAwsSubnet.map(__item => __item.id),
                securityGroupsIds: [sourceAwsSecurityGroup.id],
            },
        },
        {
            amazonMskCluster: {
                mskClusterArn: target.arn,
            },
            vpcConfig: {
                subnetIds: targetAwsSubnet.map(__item => __item.id),
                securityGroupsIds: [targetAwsSecurityGroup.id],
            },
        },
    ],
    replicationInfoList: {
        sourceKafkaClusterArn: source.arn,
        targetKafkaClusterArn: target.arn,
        targetCompressionType: "NONE",
        topicReplications: [{
            topicsToReplicates: [".*"],
        }],
        consumerGroupReplications: [{
            consumerGroupsToReplicates: [".*"],
        }],
    },
});

import pulumi
import pulumi_aws as aws
test = aws.msk.Replicator("test",
    replicator_name="test-name",
    description="test-description",
    service_execution_role_arn=source_aws_iam_role["arn"],
    kafka_clusters=[
        aws.msk.ReplicatorKafkaClusterArgs(
            amazon_msk_cluster=aws.msk.ReplicatorKafkaClusterAmazonMskClusterArgs(
                msk_cluster_arn=source["arn"],
            ),
            vpc_config=aws.msk.ReplicatorKafkaClusterVpcConfigArgs(
                subnet_ids=[__item["id"] for __item in source_aws_subnet],
                security_groups_ids=[source_aws_security_group["id"]],
            ),
        ),
        aws.msk.ReplicatorKafkaClusterArgs(
            amazon_msk_cluster=aws.msk.ReplicatorKafkaClusterAmazonMskClusterArgs(
                msk_cluster_arn=target["arn"],
            ),
            vpc_config=aws.msk.ReplicatorKafkaClusterVpcConfigArgs(
                subnet_ids=[__item["id"] for __item in target_aws_subnet],
                security_groups_ids=[target_aws_security_group["id"]],
            ),
        ),
    ],
    replication_info_list=aws.msk.ReplicatorReplicationInfoListArgs(
        source_kafka_cluster_arn=source["arn"],
        target_kafka_cluster_arn=target["arn"],
        target_compression_type="NONE",
        topic_replications=[aws.msk.ReplicatorReplicationInfoListTopicReplicationArgs(
            topics_to_replicates=[".*"],
        )],
        consumer_group_replications=[aws.msk.ReplicatorReplicationInfoListConsumerGroupReplicationArgs(
            consumer_groups_to_replicates=[".*"],
        )],
    ))

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;
return await Deployment.RunAsync(() =>
{
    var test = new Aws.Msk.Replicator("test", new()
    {
        ReplicatorName = "test-name",
        Description = "test-description",
        ServiceExecutionRoleArn = sourceAwsIamRole.Arn,
        KafkaClusters = new[]
        {
            new Aws.Msk.Inputs.ReplicatorKafkaClusterArgs
            {
                AmazonMskCluster = new Aws.Msk.Inputs.ReplicatorKafkaClusterAmazonMskClusterArgs
                {
                    MskClusterArn = source.Arn,
                },
                VpcConfig = new Aws.Msk.Inputs.ReplicatorKafkaClusterVpcConfigArgs
                {
                    SubnetIds = sourceAwsSubnet.Select(__item => __item.Id).ToList(),
                    SecurityGroupsIds = new[]
                    {
                        sourceAwsSecurityGroup.Id,
                    },
                },
            },
            new Aws.Msk.Inputs.ReplicatorKafkaClusterArgs
            {
                AmazonMskCluster = new Aws.Msk.Inputs.ReplicatorKafkaClusterAmazonMskClusterArgs
                {
                    MskClusterArn = target.Arn,
                },
                VpcConfig = new Aws.Msk.Inputs.ReplicatorKafkaClusterVpcConfigArgs
                {
                    SubnetIds = targetAwsSubnet.Select(__item => __item.Id).ToList(),
                    SecurityGroupsIds = new[]
                    {
                        targetAwsSecurityGroup.Id,
                    },
                },
            },
        },
        ReplicationInfoList = new Aws.Msk.Inputs.ReplicatorReplicationInfoListArgs
        {
            SourceKafkaClusterArn = source.Arn,
            TargetKafkaClusterArn = target.Arn,
            TargetCompressionType = "NONE",
            TopicReplications = new[]
            {
                new Aws.Msk.Inputs.ReplicatorReplicationInfoListTopicReplicationArgs
                {
                    TopicsToReplicates = new[]
                    {
                        ".*",
                    },
                },
            },
            ConsumerGroupReplications = new[]
            {
                new Aws.Msk.Inputs.ReplicatorReplicationInfoListConsumerGroupReplicationArgs
                {
                    ConsumerGroupsToReplicates = new[]
                    {
                        ".*",
                    },
                },
            },
        },
    });
});

package main
import (
	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/msk"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := msk.NewReplicator(ctx, "test", &msk.ReplicatorArgs{
ReplicatorName: pulumi.String("test-name"),
Description: pulumi.String("test-description"),
ServiceExecutionRoleArn: pulumi.Any(sourceAwsIamRole.Arn),
KafkaClusters: msk.ReplicatorKafkaClusterArray{
&msk.ReplicatorKafkaClusterArgs{
AmazonMskCluster: &msk.ReplicatorKafkaClusterAmazonMskClusterArgs{
MskClusterArn: pulumi.Any(source.Arn),
},
VpcConfig: &msk.ReplicatorKafkaClusterVpcConfigArgs{
SubnetIds: %!v(PANIC=Format method: fatal: A failure has occurred: unlowered splat expression @ example.pp:9,27-48),
SecurityGroupsIds: pulumi.StringArray{
sourceAwsSecurityGroup.Id,
},
},
},
&msk.ReplicatorKafkaClusterArgs{
AmazonMskCluster: &msk.ReplicatorKafkaClusterAmazonMskClusterArgs{
MskClusterArn: pulumi.Any(target.Arn),
},
VpcConfig: &msk.ReplicatorKafkaClusterVpcConfigArgs{
SubnetIds: %!v(PANIC=Format method: fatal: A failure has occurred: unlowered splat expression @ example.pp:17,27-48),
SecurityGroupsIds: pulumi.StringArray{
targetAwsSecurityGroup.Id,
},
},
},
},
ReplicationInfoList: &msk.ReplicatorReplicationInfoListArgs{
SourceKafkaClusterArn: pulumi.Any(source.Arn),
TargetKafkaClusterArn: pulumi.Any(target.Arn),
TargetCompressionType: pulumi.String("NONE"),
TopicReplications: msk.ReplicatorReplicationInfoListTopicReplicationArray{
&msk.ReplicatorReplicationInfoListTopicReplicationArgs{
TopicsToReplicates: pulumi.StringArray{
pulumi.String(".*"),
},
},
},
ConsumerGroupReplications: msk.ReplicatorReplicationInfoListConsumerGroupReplicationArray{
&msk.ReplicatorReplicationInfoListConsumerGroupReplicationArgs{
ConsumerGroupsToReplicates: pulumi.StringArray{
pulumi.String(".*"),
},
},
},
},
})
if err != nil {
return err
}
return nil
})
}

package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.msk.Replicator;
import com.pulumi.aws.msk.ReplicatorArgs;
import com.pulumi.aws.msk.inputs.ReplicatorKafkaClusterArgs;
import com.pulumi.aws.msk.inputs.ReplicatorKafkaClusterAmazonMskClusterArgs;
import com.pulumi.aws.msk.inputs.ReplicatorKafkaClusterVpcConfigArgs;
import com.pulumi.aws.msk.inputs.ReplicatorReplicationInfoListArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }
    public static void stack(Context ctx) {
        var test = new Replicator("test", ReplicatorArgs.builder()
            .replicatorName("test-name")
            .description("test-description")
            .serviceExecutionRoleArn(sourceAwsIamRole.arn())
            .kafkaClusters(
                ReplicatorKafkaClusterArgs.builder()
                    .amazonMskCluster(ReplicatorKafkaClusterAmazonMskClusterArgs.builder()
                        .mskClusterArn(source.arn())
                        .build())
                    .vpcConfig(ReplicatorKafkaClusterVpcConfigArgs.builder()
                        .subnetIds(sourceAwsSubnet.stream().map(element -> element.id()).collect(toList()))
                        .securityGroupsIds(sourceAwsSecurityGroup.id())
                        .build())
                    .build(),
                ReplicatorKafkaClusterArgs.builder()
                    .amazonMskCluster(ReplicatorKafkaClusterAmazonMskClusterArgs.builder()
                        .mskClusterArn(target.arn())
                        .build())
                    .vpcConfig(ReplicatorKafkaClusterVpcConfigArgs.builder()
                        .subnetIds(targetAwsSubnet.stream().map(element -> element.id()).collect(toList()))
                        .securityGroupsIds(targetAwsSecurityGroup.id())
                        .build())
                    .build())
            .replicationInfoList(ReplicatorReplicationInfoListArgs.builder()
                .sourceKafkaClusterArn(source.arn())
                .targetKafkaClusterArn(target.arn())
                .targetCompressionType("NONE")
                .topicReplications(ReplicatorReplicationInfoListTopicReplicationArgs.builder()
                    .topicsToReplicates(".*")
                    .build())
                .consumerGroupReplications(ReplicatorReplicationInfoListConsumerGroupReplicationArgs.builder()
                    .consumerGroupsToReplicates(".*")
                    .build())
                .build())
            .build());
    }
}

$ pulumi import aws:msk/replicator:Replicator example arn:aws:kafka:us-west-2:123456789012:configuration/example/279c0212-d057-4dba-9aa9-1c4e5a25bfc7-3