pulumi-aws-kotlin/com.pulumi.aws.msk.kotlin/Replicator

Replicator

class Replicator : KotlinCustomResource

Resource for managing an AWS Managed Streaming for Kafka Replicator.

Example Usage

Basic Usage

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&#46;id],
            },
        },
        {
            amazonMskCluster: {
                mskClusterArn: target.arn,
            },
            vpcConfig: {
                subnetIds: targetAwsSubnet.map(__item => __item.id),
                securityGroupsIds: [targetAwsSecurityGroup&#46;id],
            },
        },
    ],
    replicationInfoList: {
        sourceKafkaClusterArn: source.arn,
        targetKafkaClusterArn: target.arn,
        targetCompressionType: "NONE",
        topicReplications: [{
            topicNameConfiguration: {
                type: "PREFIXED_WITH_SOURCE_CLUSTER_ALIAS",
            },
            topicsToReplicates: ["&#46;*"],
            startingPosition: {
                type: "LATEST",
            },
        }],
        consumerGroupReplications: [{
            consumerGroupsToReplicates: ["&#46;*"],
        }],
    },
});

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=[
        {
            "amazon_msk_cluster": {
                "msk_cluster_arn": source["arn"],
            },
            "vpc_config": {
                "subnet_ids": [__item["id"] for __item in source_aws_subnet],
                "security_groups_ids": [source_aws_security_group["id"]],
            },
        },
        {
            "amazon_msk_cluster": {
                "msk_cluster_arn": target["arn"],
            },
            "vpc_config": {
                "subnet_ids": [__item["id"] for __item in target_aws_subnet],
                "security_groups_ids": [target_aws_security_group["id"]],
            },
        },
    ],
    replication_info_list={
        "source_kafka_cluster_arn": source["arn"],
        "target_kafka_cluster_arn": target["arn"],
        "target_compression_type": "NONE",
        "topic_replications": [{
            "topic_name_configuration": {
                "type": "PREFIXED_WITH_SOURCE_CLUSTER_ALIAS",
            },
            "topics_to_replicates": ["&#46;*"],
            "starting_position": {
                "type": "LATEST",
            },
        }],
        "consumer_group_replications": [{
            "consumer_groups_to_replicates": ["&#46;*"],
        }],
    })

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
                {
                    TopicNameConfiguration = new Aws.Msk.Inputs.ReplicatorReplicationInfoListTopicReplicationTopicNameConfigurationArgs
                    {
                        Type = "PREFIXED_WITH_SOURCE_CLUSTER_ALIAS",
                    },
                    TopicsToReplicates = new[]
                    {
                        ".*",
                    },
                    StartingPosition = new Aws.Msk.Inputs.ReplicatorReplicationInfoListTopicReplicationStartingPositionArgs
                    {
                        Type = "LATEST",
                    },
                },
            },
            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: []pulumi.String(%!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: []pulumi.String(%!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{
TopicNameConfiguration: &msk.ReplicatorReplicationInfoListTopicReplicationTopicNameConfigurationArgs{
Type: pulumi.String("PREFIXED_WITH_SOURCE_CLUSTER_ALIAS"),
},
TopicsToReplicates: pulumi.StringArray{
pulumi.String(".*"),
},
StartingPosition: &msk.ReplicatorReplicationInfoListTopicReplicationStartingPositionArgs{
Type: pulumi.String("LATEST"),
},
},
},
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()
                    .topicNameConfiguration(ReplicatorReplicationInfoListTopicReplicationTopicNameConfigurationArgs.builder()
                        .type("PREFIXED_WITH_SOURCE_CLUSTER_ALIAS")
                        .build())
                    .topicsToReplicates(".*")
                    .startingPosition(ReplicatorReplicationInfoListTopicReplicationStartingPositionArgs.builder()
                        .type("LATEST")
                        .build())
                    .build())
                .consumerGroupReplications(ReplicatorReplicationInfoListConsumerGroupReplicationArgs.builder()
                    .consumerGroupsToReplicates(".*")
                    .build())
                .build())
            .build());
    }
}

Import

Using pulumi import, import MSK replicators using the replicator ARN. For example:

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