Replicator

AWS Cloud Control v1.63.0, May 4 26

We recommend new projects start with resources from the AWS provider.

Viewing docs for AWS Cloud Control v1.63.0
published on Monday, May 4, 2026 by Pulumi

Schema (JSON)

pulumi/pulumi-aws-native

We recommend new projects start with resources from the AWS provider.

Viewing docs for AWS Cloud Control v1.63.0
published on Monday, May 4, 2026 by Pulumi

Schema (JSON)

pulumi/pulumi-aws-native

Create Replicator Resource

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

Constructor syntax

new Replicator(name: string, args: ReplicatorArgs, opts?: CustomResourceOptions);

@overload
def Replicator(resource_name: str,
               args: ReplicatorArgs,
               opts: Optional[ResourceOptions] = None)

@overload
def Replicator(resource_name: str,
               opts: Optional[ResourceOptions] = None,
               kafka_clusters: Optional[Sequence[ReplicatorKafkaClusterArgs]] = None,
               replication_info_list: Optional[Sequence[ReplicatorReplicationInfoArgs]] = None,
               service_execution_role_arn: Optional[str] = None,
               description: Optional[str] = None,
               log_delivery: Optional[LogDeliveryArgs] = None,
               replicator_name: Optional[str] = None,
               tags: Optional[Sequence[_root_inputs.TagArgs]] = None)

func NewReplicator(ctx *Context, name string, args ReplicatorArgs, opts ...ResourceOption) (*Replicator, error)

public Replicator(string name, ReplicatorArgs args, CustomResourceOptions? opts = null)

public Replicator(String name, ReplicatorArgs args)
public Replicator(String name, ReplicatorArgs args, CustomResourceOptions options)

type: aws-native:msk:Replicator
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.

Parameters

name string: The unique name of the resource.
args ReplicatorArgs: 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 ReplicatorArgs: 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 ReplicatorArgs: The arguments to resource properties.
opts ResourceOption: Bag of options to control resource's behavior.

name string: The unique name of the resource.
args ReplicatorArgs: The arguments to resource properties.
opts CustomResourceOptions: Bag of options to control resource's behavior.

name String: The unique name of the resource.
args ReplicatorArgs: The arguments to resource properties.
options CustomResourceOptions: Bag of options to control resource's behavior.

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

KafkaClusters List<Pulumi.AwsNative.Msk.Inputs.ReplicatorKafkaCluster>: Specifies a list of Kafka clusters which are targets of the replicator.
ReplicationInfoList List<Pulumi.AwsNative.Msk.Inputs.ReplicatorReplicationInfo>: A list of replication configurations, where each configuration targets a given source cluster to target cluster replication flow.
ServiceExecutionRoleArn string: The Amazon Resource Name (ARN) of the IAM role used by the replicator to access external resources.
Description string: A summary description of the replicator.
LogDelivery Pulumi.AwsNative.Msk.Inputs.LogDelivery: Configuration for log delivery for the replicator.
ReplicatorName string: The name of the replicator.
Tags List<Pulumi.AwsNative.Inputs.Tag>: A collection of tags associated with a resource

KafkaClusters []ReplicatorKafkaClusterArgs: Specifies a list of Kafka clusters which are targets of the replicator.
ReplicationInfoList []ReplicatorReplicationInfoArgs: A list of replication configurations, where each configuration targets a given source cluster to target cluster replication flow.
ServiceExecutionRoleArn string: The Amazon Resource Name (ARN) of the IAM role used by the replicator to access external resources.
Description string: A summary description of the replicator.
LogDelivery LogDeliveryArgs: Configuration for log delivery for the replicator.
ReplicatorName string: The name of the replicator.
Tags TagArgs: A collection of tags associated with a resource

kafkaClusters List<ReplicatorKafkaCluster>: Specifies a list of Kafka clusters which are targets of the replicator.
replicationInfoList List<ReplicatorReplicationInfo>: A list of replication configurations, where each configuration targets a given source cluster to target cluster replication flow.
serviceExecutionRoleArn String: The Amazon Resource Name (ARN) of the IAM role used by the replicator to access external resources.
description String: A summary description of the replicator.
logDelivery LogDelivery: Configuration for log delivery for the replicator.
replicatorName String: The name of the replicator.
tags List<Tag>: A collection of tags associated with a resource

kafkaClusters ReplicatorKafkaCluster[]: Specifies a list of Kafka clusters which are targets of the replicator.
replicationInfoList ReplicatorReplicationInfo[]: A list of replication configurations, where each configuration targets a given source cluster to target cluster replication flow.
serviceExecutionRoleArn string: The Amazon Resource Name (ARN) of the IAM role used by the replicator to access external resources.
description string: A summary description of the replicator.
logDelivery LogDelivery: Configuration for log delivery for the replicator.
replicatorName string: The name of the replicator.
tags Tag[]: A collection of tags associated with a resource

kafka_clusters Sequence[ReplicatorKafkaClusterArgs]: Specifies a list of Kafka clusters which are targets of the replicator.
replication_info_list Sequence[ReplicatorReplicationInfoArgs]: A list of replication configurations, where each configuration targets a given source cluster to target cluster replication flow.
service_execution_role_arn str: The Amazon Resource Name (ARN) of the IAM role used by the replicator to access external resources.
description str: A summary description of the replicator.
log_delivery LogDeliveryArgs: Configuration for log delivery for the replicator.
replicator_name str: The name of the replicator.
tags Sequence[TagArgs]: A collection of tags associated with a resource

kafkaClusters List<Property Map>: Specifies a list of Kafka clusters which are targets of the replicator.
replicationInfoList List<Property Map>: A list of replication configurations, where each configuration targets a given source cluster to target cluster replication flow.
serviceExecutionRoleArn String: The Amazon Resource Name (ARN) of the IAM role used by the replicator to access external resources.
description String: A summary description of the replicator.
logDelivery Property Map: Configuration for log delivery for the replicator.
replicatorName String: The name of the replicator.
tags List<Property Map>: A collection of tags associated with a resource

Outputs

All input properties are implicitly available as output properties. Additionally, the Replicator resource produces the following output properties:

CurrentVersion string: The current version of the MSK replicator.
Id string: The provider-assigned unique ID for this managed resource.
ReplicatorArn string: Amazon Resource Name for the created replicator.

CurrentVersion string: The current version of the MSK replicator.
Id string: The provider-assigned unique ID for this managed resource.
ReplicatorArn string: Amazon Resource Name for the created replicator.

currentVersion String: The current version of the MSK replicator.
id String: The provider-assigned unique ID for this managed resource.
replicatorArn String: Amazon Resource Name for the created replicator.

currentVersion string: The current version of the MSK replicator.
id string: The provider-assigned unique ID for this managed resource.
replicatorArn string: Amazon Resource Name for the created replicator.

current_version str: The current version of the MSK replicator.
id str: The provider-assigned unique ID for this managed resource.
replicator_arn str: Amazon Resource Name for the created replicator.

currentVersion String: The current version of the MSK replicator.
id String: The provider-assigned unique ID for this managed resource.
replicatorArn String: Amazon Resource Name for the created replicator.

Supporting Types

LogDelivery, LogDeliveryArgs

Configuration for log delivery for the replicator.

ReplicatorLogDelivery Pulumi.AwsNative.Msk.Inputs.ReplicatorLogDelivery: The replicator logs configuration.

ReplicatorLogDelivery ReplicatorLogDelivery: The replicator logs configuration.

replicatorLogDelivery ReplicatorLogDelivery: The replicator logs configuration.

replicatorLogDelivery ReplicatorLogDelivery: The replicator logs configuration.

replicator_log_delivery ReplicatorLogDelivery: The replicator logs configuration.

replicatorLogDelivery Property Map: The replicator logs configuration.

ReplicatorAmazonMskCluster, ReplicatorAmazonMskClusterArgs

Details of an Amazon MSK cluster.

MskClusterArn string: The ARN of an Amazon MSK cluster.

MskClusterArn string: The ARN of an Amazon MSK cluster.

mskClusterArn String: The ARN of an Amazon MSK cluster.

mskClusterArn string: The ARN of an Amazon MSK cluster.

msk_cluster_arn str: The ARN of an Amazon MSK cluster.

mskClusterArn String: The ARN of an Amazon MSK cluster.

ReplicatorApacheKafkaCluster, ReplicatorApacheKafkaClusterArgs

Details of an Apache Kafka cluster.

ApacheKafkaClusterId string: The ID of the Apache Kafka cluster.
BootstrapBrokerString string: The bootstrap broker string of the Apache Kafka cluster.

ApacheKafkaClusterId string: The ID of the Apache Kafka cluster.
BootstrapBrokerString string: The bootstrap broker string of the Apache Kafka cluster.

apacheKafkaClusterId String: The ID of the Apache Kafka cluster.
bootstrapBrokerString String: The bootstrap broker string of the Apache Kafka cluster.

apacheKafkaClusterId string: The ID of the Apache Kafka cluster.
bootstrapBrokerString string: The bootstrap broker string of the Apache Kafka cluster.

apache_kafka_cluster_id str: The ID of the Apache Kafka cluster.
bootstrap_broker_string str: The bootstrap broker string of the Apache Kafka cluster.

apacheKafkaClusterId String: The ID of the Apache Kafka cluster.
bootstrapBrokerString String: The bootstrap broker string of the Apache Kafka cluster.

ReplicatorCloudWatchLogs, ReplicatorCloudWatchLogsArgs

Details about delivering logs to CloudWatch Logs.

Enabled bool: Whether log delivery to CloudWatch Logs is enabled.
LogGroup string: The CloudWatch log group that is the destination for log delivery.

Enabled bool: Whether log delivery to CloudWatch Logs is enabled.
LogGroup string: The CloudWatch log group that is the destination for log delivery.

enabled Boolean: Whether log delivery to CloudWatch Logs is enabled.
logGroup String: The CloudWatch log group that is the destination for log delivery.

enabled boolean: Whether log delivery to CloudWatch Logs is enabled.
logGroup string: The CloudWatch log group that is the destination for log delivery.

enabled bool: Whether log delivery to CloudWatch Logs is enabled.
log_group str: The CloudWatch log group that is the destination for log delivery.

enabled Boolean: Whether log delivery to CloudWatch Logs is enabled.
logGroup String: The CloudWatch log group that is the destination for log delivery.

ReplicatorConsumerGroupOffsetSyncMode, ReplicatorConsumerGroupOffsetSyncModeArgs

Legacy: LEGACY
Enhanced: ENHANCED

ReplicatorConsumerGroupOffsetSyncModeLegacy: LEGACY
ReplicatorConsumerGroupOffsetSyncModeEnhanced: ENHANCED

Legacy: LEGACY
Enhanced: ENHANCED

Legacy: LEGACY
Enhanced: ENHANCED

LEGACY: LEGACY
ENHANCED: ENHANCED

"LEGACY": LEGACY
"ENHANCED": ENHANCED

ReplicatorConsumerGroupReplication, ReplicatorConsumerGroupReplicationArgs

Configuration relating to consumer group replication.

ConsumerGroupsToReplicate List<string>: List of regular expression patterns indicating the consumer groups to copy.
ConsumerGroupOffsetSyncMode Pulumi.AwsNative.Msk.ReplicatorConsumerGroupOffsetSyncMode: The consumer group offset synchronization mode.
ConsumerGroupsToExclude List<string>: List of regular expression patterns indicating the consumer groups that should not be replicated.
DetectAndCopyNewConsumerGroups bool: Whether to periodically check for new consumer groups.
SynchroniseConsumerGroupOffsets bool: Whether to periodically write the translated offsets to __consumer_offsets topic in target cluster.

ConsumerGroupsToReplicate []string: List of regular expression patterns indicating the consumer groups to copy.
ConsumerGroupOffsetSyncMode ReplicatorConsumerGroupOffsetSyncMode: The consumer group offset synchronization mode.
ConsumerGroupsToExclude []string: List of regular expression patterns indicating the consumer groups that should not be replicated.
DetectAndCopyNewConsumerGroups bool: Whether to periodically check for new consumer groups.
SynchroniseConsumerGroupOffsets bool: Whether to periodically write the translated offsets to __consumer_offsets topic in target cluster.

consumerGroupsToReplicate List<String>: List of regular expression patterns indicating the consumer groups to copy.
consumerGroupOffsetSyncMode ReplicatorConsumerGroupOffsetSyncMode: The consumer group offset synchronization mode.
consumerGroupsToExclude List<String>: List of regular expression patterns indicating the consumer groups that should not be replicated.
detectAndCopyNewConsumerGroups Boolean: Whether to periodically check for new consumer groups.
synchroniseConsumerGroupOffsets Boolean: Whether to periodically write the translated offsets to __consumer_offsets topic in target cluster.

consumerGroupsToReplicate string[]: List of regular expression patterns indicating the consumer groups to copy.
consumerGroupOffsetSyncMode ReplicatorConsumerGroupOffsetSyncMode: The consumer group offset synchronization mode.
consumerGroupsToExclude string[]: List of regular expression patterns indicating the consumer groups that should not be replicated.
detectAndCopyNewConsumerGroups boolean: Whether to periodically check for new consumer groups.
synchroniseConsumerGroupOffsets boolean: Whether to periodically write the translated offsets to __consumer_offsets topic in target cluster.

consumer_groups_to_replicate Sequence[str]: List of regular expression patterns indicating the consumer groups to copy.
consumer_group_offset_sync_mode ReplicatorConsumerGroupOffsetSyncMode: The consumer group offset synchronization mode.
consumer_groups_to_exclude Sequence[str]: List of regular expression patterns indicating the consumer groups that should not be replicated.
detect_and_copy_new_consumer_groups bool: Whether to periodically check for new consumer groups.
synchronise_consumer_group_offsets bool: Whether to periodically write the translated offsets to __consumer_offsets topic in target cluster.

consumerGroupsToReplicate List<String>: List of regular expression patterns indicating the consumer groups to copy.
consumerGroupOffsetSyncMode "LEGACY" | "ENHANCED": The consumer group offset synchronization mode.
consumerGroupsToExclude List<String>: List of regular expression patterns indicating the consumer groups that should not be replicated.
detectAndCopyNewConsumerGroups Boolean: Whether to periodically check for new consumer groups.
synchroniseConsumerGroupOffsets Boolean: Whether to periodically write the translated offsets to __consumer_offsets topic in target cluster.

ReplicatorFirehose, ReplicatorFirehoseArgs

Details about delivering logs to Firehose.

Enabled bool: Whether log delivery to Firehose is enabled.
DeliveryStream string: The Firehose delivery stream that is the destination for log delivery.

Enabled bool: Whether log delivery to Firehose is enabled.
DeliveryStream string: The Firehose delivery stream that is the destination for log delivery.

enabled Boolean: Whether log delivery to Firehose is enabled.
deliveryStream String: The Firehose delivery stream that is the destination for log delivery.

enabled boolean: Whether log delivery to Firehose is enabled.
deliveryStream string: The Firehose delivery stream that is the destination for log delivery.

enabled bool: Whether log delivery to Firehose is enabled.
delivery_stream str: The Firehose delivery stream that is the destination for log delivery.

enabled Boolean: Whether log delivery to Firehose is enabled.
deliveryStream String: The Firehose delivery stream that is the destination for log delivery.

ReplicatorKafkaCluster, ReplicatorKafkaClusterArgs

Details of a Kafka cluster for replication.

AmazonMskCluster Pulumi.AwsNative.Msk.Inputs.ReplicatorAmazonMskCluster: Details of an Amazon MSK cluster.
ApacheKafkaCluster Pulumi.AwsNative.Msk.Inputs.ReplicatorApacheKafkaCluster: Details of an Apache Kafka cluster.
ClientAuthentication Pulumi.AwsNative.Msk.Inputs.ReplicatorKafkaClusterClientAuthentication: Details of the client authentication used by the Apache Kafka cluster.
EncryptionInTransit Pulumi.AwsNative.Msk.Inputs.ReplicatorKafkaClusterEncryptionInTransit: Details of encryption in transit to the Apache Kafka cluster.
VpcConfig Pulumi.AwsNative.Msk.Inputs.ReplicatorKafkaClusterClientVpcConfig: Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.

AmazonMskCluster ReplicatorAmazonMskCluster: Details of an Amazon MSK cluster.
ApacheKafkaCluster ReplicatorApacheKafkaCluster: Details of an Apache Kafka cluster.
ClientAuthentication ReplicatorKafkaClusterClientAuthentication: Details of the client authentication used by the Apache Kafka cluster.
EncryptionInTransit ReplicatorKafkaClusterEncryptionInTransit: Details of encryption in transit to the Apache Kafka cluster.
VpcConfig ReplicatorKafkaClusterClientVpcConfig: Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.

amazonMskCluster ReplicatorAmazonMskCluster: Details of an Amazon MSK cluster.
apacheKafkaCluster ReplicatorApacheKafkaCluster: Details of an Apache Kafka cluster.
clientAuthentication ReplicatorKafkaClusterClientAuthentication: Details of the client authentication used by the Apache Kafka cluster.
encryptionInTransit ReplicatorKafkaClusterEncryptionInTransit: Details of encryption in transit to the Apache Kafka cluster.
vpcConfig ReplicatorKafkaClusterClientVpcConfig: Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.

amazonMskCluster ReplicatorAmazonMskCluster: Details of an Amazon MSK cluster.
apacheKafkaCluster ReplicatorApacheKafkaCluster: Details of an Apache Kafka cluster.
clientAuthentication ReplicatorKafkaClusterClientAuthentication: Details of the client authentication used by the Apache Kafka cluster.
encryptionInTransit ReplicatorKafkaClusterEncryptionInTransit: Details of encryption in transit to the Apache Kafka cluster.
vpcConfig ReplicatorKafkaClusterClientVpcConfig: Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.

amazon_msk_cluster ReplicatorAmazonMskCluster: Details of an Amazon MSK cluster.
apache_kafka_cluster ReplicatorApacheKafkaCluster: Details of an Apache Kafka cluster.
client_authentication ReplicatorKafkaClusterClientAuthentication: Details of the client authentication used by the Apache Kafka cluster.
encryption_in_transit ReplicatorKafkaClusterEncryptionInTransit: Details of encryption in transit to the Apache Kafka cluster.
vpc_config ReplicatorKafkaClusterClientVpcConfig: Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.

amazonMskCluster Property Map: Details of an Amazon MSK cluster.
apacheKafkaCluster Property Map: Details of an Apache Kafka cluster.
clientAuthentication Property Map: Details of the client authentication used by the Apache Kafka cluster.
encryptionInTransit Property Map: Details of encryption in transit to the Apache Kafka cluster.
vpcConfig Property Map: Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.

ReplicatorKafkaClusterClientAuthentication, ReplicatorKafkaClusterClientAuthenticationArgs

Details of the client authentication used by the Apache Kafka cluster.

SaslScram Pulumi.AwsNative.Msk.Inputs.ReplicatorKafkaClusterSaslScramAuthentication: Details for SASL/SCRAM client authentication.

SaslScram ReplicatorKafkaClusterSaslScramAuthentication: Details for SASL/SCRAM client authentication.

saslScram ReplicatorKafkaClusterSaslScramAuthentication: Details for SASL/SCRAM client authentication.

saslScram ReplicatorKafkaClusterSaslScramAuthentication: Details for SASL/SCRAM client authentication.

sasl_scram ReplicatorKafkaClusterSaslScramAuthentication: Details for SASL/SCRAM client authentication.

saslScram Property Map: Details for SASL/SCRAM client authentication.

ReplicatorKafkaClusterClientVpcConfig, ReplicatorKafkaClusterClientVpcConfigArgs

Details of an Amazon VPC which has network connectivity to the Kafka cluster.

SubnetIds List<string>: The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.
SecurityGroupIds List<string>: The AWS security groups to associate with the elastic network interfaces in order to specify what the replicator has access to. If a security group is not specified, the default security group associated with the VPC is used.

SubnetIds []string: The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.
SecurityGroupIds []string: The AWS security groups to associate with the elastic network interfaces in order to specify what the replicator has access to. If a security group is not specified, the default security group associated with the VPC is used.

subnetIds List<String>: The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.
securityGroupIds List<String>: The AWS security groups to associate with the elastic network interfaces in order to specify what the replicator has access to. If a security group is not specified, the default security group associated with the VPC is used.

subnetIds string[]: The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.
securityGroupIds string[]: The AWS security groups to associate with the elastic network interfaces in order to specify what the replicator has access to. If a security group is not specified, the default security group associated with the VPC is used.

subnet_ids Sequence[str]: The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.
security_group_ids Sequence[str]: The AWS security groups to associate with the elastic network interfaces in order to specify what the replicator has access to. If a security group is not specified, the default security group associated with the VPC is used.

subnetIds List<String>: The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.
securityGroupIds List<String>: The AWS security groups to associate with the elastic network interfaces in order to specify what the replicator has access to. If a security group is not specified, the default security group associated with the VPC is used.

ReplicatorKafkaClusterEncryptionInTransit, ReplicatorKafkaClusterEncryptionInTransitArgs

Details of encryption in transit to the Apache Kafka cluster.

EncryptionType Pulumi.AwsNative.Msk.ReplicatorKafkaClusterEncryptionInTransitType: The type of encryption in transit to the Apache Kafka cluster.
RootCaCertificate string: The root CA certificate.

EncryptionType ReplicatorKafkaClusterEncryptionInTransitType: The type of encryption in transit to the Apache Kafka cluster.
RootCaCertificate string: The root CA certificate.

encryptionType ReplicatorKafkaClusterEncryptionInTransitType: The type of encryption in transit to the Apache Kafka cluster.
rootCaCertificate String: The root CA certificate.

encryptionType ReplicatorKafkaClusterEncryptionInTransitType: The type of encryption in transit to the Apache Kafka cluster.
rootCaCertificate string: The root CA certificate.

encryption_type ReplicatorKafkaClusterEncryptionInTransitType: The type of encryption in transit to the Apache Kafka cluster.
root_ca_certificate str: The root CA certificate.

encryptionType "TLS": The type of encryption in transit to the Apache Kafka cluster.
rootCaCertificate String: The root CA certificate.

ReplicatorKafkaClusterEncryptionInTransitType, ReplicatorKafkaClusterEncryptionInTransitTypeArgs

Tls: TLS

ReplicatorKafkaClusterEncryptionInTransitTypeTls: TLS

Tls: TLS

Tls: TLS

TLS: TLS

"TLS": TLS

ReplicatorKafkaClusterSaslScramAuthentication, ReplicatorKafkaClusterSaslScramAuthenticationArgs

Details for SASL/SCRAM client authentication.

Mechanism Pulumi.AwsNative.Msk.ReplicatorKafkaClusterSaslScramMechanism: The SASL/SCRAM authentication mechanism.
SecretArn string: The Amazon Resource Name (ARN) of the Secrets Manager secret.

Mechanism ReplicatorKafkaClusterSaslScramMechanism: The SASL/SCRAM authentication mechanism.
SecretArn string: The Amazon Resource Name (ARN) of the Secrets Manager secret.

mechanism ReplicatorKafkaClusterSaslScramMechanism: The SASL/SCRAM authentication mechanism.
secretArn String: The Amazon Resource Name (ARN) of the Secrets Manager secret.

mechanism ReplicatorKafkaClusterSaslScramMechanism: The SASL/SCRAM authentication mechanism.
secretArn string: The Amazon Resource Name (ARN) of the Secrets Manager secret.

mechanism ReplicatorKafkaClusterSaslScramMechanism: The SASL/SCRAM authentication mechanism.
secret_arn str: The Amazon Resource Name (ARN) of the Secrets Manager secret.

mechanism "SHA256" | "SHA512": The SASL/SCRAM authentication mechanism.
secretArn String: The Amazon Resource Name (ARN) of the Secrets Manager secret.

ReplicatorKafkaClusterSaslScramMechanism, ReplicatorKafkaClusterSaslScramMechanismArgs

Sha256: SHA256
Sha512: SHA512

ReplicatorKafkaClusterSaslScramMechanismSha256: SHA256
ReplicatorKafkaClusterSaslScramMechanismSha512: SHA512

Sha256: SHA256
Sha512: SHA512

Sha256: SHA256
Sha512: SHA512

SHA256: SHA256
SHA512: SHA512

"SHA256": SHA256
"SHA512": SHA512

ReplicatorLogDelivery, ReplicatorLogDeliveryArgs

Details of the log delivery for the replicator.

CloudWatchLogs Pulumi.AwsNative.Msk.Inputs.ReplicatorCloudWatchLogs: Details of the CloudWatch Logs destination for replicator logs.
Firehose Pulumi.AwsNative.Msk.Inputs.ReplicatorFirehose: Details of the Kinesis Data Firehose delivery stream that is the destination for replicator logs.
S3 Pulumi.AwsNative.Msk.Inputs.ReplicatorS3: Details of the Amazon S3 destination for replicator logs.

CloudWatchLogs ReplicatorCloudWatchLogs: Details of the CloudWatch Logs destination for replicator logs.
Firehose ReplicatorFirehose: Details of the Kinesis Data Firehose delivery stream that is the destination for replicator logs.
S3 ReplicatorS3: Details of the Amazon S3 destination for replicator logs.

cloudWatchLogs ReplicatorCloudWatchLogs: Details of the CloudWatch Logs destination for replicator logs.
firehose ReplicatorFirehose: Details of the Kinesis Data Firehose delivery stream that is the destination for replicator logs.
s3 ReplicatorS3: Details of the Amazon S3 destination for replicator logs.

cloudWatchLogs ReplicatorCloudWatchLogs: Details of the CloudWatch Logs destination for replicator logs.
firehose ReplicatorFirehose: Details of the Kinesis Data Firehose delivery stream that is the destination for replicator logs.
s3 ReplicatorS3: Details of the Amazon S3 destination for replicator logs.

cloud_watch_logs ReplicatorCloudWatchLogs: Details of the CloudWatch Logs destination for replicator logs.
firehose ReplicatorFirehose: Details of the Kinesis Data Firehose delivery stream that is the destination for replicator logs.
s3 ReplicatorS3: Details of the Amazon S3 destination for replicator logs.

cloudWatchLogs Property Map: Details of the CloudWatch Logs destination for replicator logs.
firehose Property Map: Details of the Kinesis Data Firehose delivery stream that is the destination for replicator logs.
s3 Property Map: Details of the Amazon S3 destination for replicator logs.

ReplicatorReplicationInfo, ReplicatorReplicationInfoArgs

Specifies configuration for replication between a source and target Kafka cluster.

ConsumerGroupReplication Pulumi.AwsNative.Msk.Inputs.ReplicatorConsumerGroupReplication: Configuration relating to consumer group replication.
TargetCompressionType Pulumi.AwsNative.Msk.ReplicatorReplicationInfoTargetCompressionType: The type of compression to use writing records to target Kafka cluster.
TopicReplication Pulumi.AwsNative.Msk.Inputs.ReplicatorTopicReplication: Configuration relating to topic replication.
SourceKafkaClusterArn string: Amazon Resource Name of the source Kafka cluster.
SourceKafkaClusterId string: The ID of the source Kafka cluster.
TargetKafkaClusterArn string: Amazon Resource Name of the target Kafka cluster.
TargetKafkaClusterId string: The ID of the target Kafka cluster.

ConsumerGroupReplication ReplicatorConsumerGroupReplication: Configuration relating to consumer group replication.
TargetCompressionType ReplicatorReplicationInfoTargetCompressionType: The type of compression to use writing records to target Kafka cluster.
TopicReplication ReplicatorTopicReplication: Configuration relating to topic replication.
SourceKafkaClusterArn string: Amazon Resource Name of the source Kafka cluster.
SourceKafkaClusterId string: The ID of the source Kafka cluster.
TargetKafkaClusterArn string: Amazon Resource Name of the target Kafka cluster.
TargetKafkaClusterId string: The ID of the target Kafka cluster.

consumerGroupReplication ReplicatorConsumerGroupReplication: Configuration relating to consumer group replication.
targetCompressionType ReplicatorReplicationInfoTargetCompressionType: The type of compression to use writing records to target Kafka cluster.
topicReplication ReplicatorTopicReplication: Configuration relating to topic replication.
sourceKafkaClusterArn String: Amazon Resource Name of the source Kafka cluster.
sourceKafkaClusterId String: The ID of the source Kafka cluster.
targetKafkaClusterArn String: Amazon Resource Name of the target Kafka cluster.
targetKafkaClusterId String: The ID of the target Kafka cluster.

consumerGroupReplication ReplicatorConsumerGroupReplication: Configuration relating to consumer group replication.
targetCompressionType ReplicatorReplicationInfoTargetCompressionType: The type of compression to use writing records to target Kafka cluster.
topicReplication ReplicatorTopicReplication: Configuration relating to topic replication.
sourceKafkaClusterArn string: Amazon Resource Name of the source Kafka cluster.
sourceKafkaClusterId string: The ID of the source Kafka cluster.
targetKafkaClusterArn string: Amazon Resource Name of the target Kafka cluster.
targetKafkaClusterId string: The ID of the target Kafka cluster.

consumer_group_replication ReplicatorConsumerGroupReplication: Configuration relating to consumer group replication.
target_compression_type ReplicatorReplicationInfoTargetCompressionType: The type of compression to use writing records to target Kafka cluster.
topic_replication ReplicatorTopicReplication: Configuration relating to topic replication.
source_kafka_cluster_arn str: Amazon Resource Name of the source Kafka cluster.
source_kafka_cluster_id str: The ID of the source Kafka cluster.
target_kafka_cluster_arn str: Amazon Resource Name of the target Kafka cluster.
target_kafka_cluster_id str: The ID of the target Kafka cluster.

consumerGroupReplication Property Map: Configuration relating to consumer group replication.
targetCompressionType "NONE" | "GZIP" | "SNAPPY" | "LZ4" | "ZSTD": The type of compression to use writing records to target Kafka cluster.
topicReplication Property Map: Configuration relating to topic replication.
sourceKafkaClusterArn String: Amazon Resource Name of the source Kafka cluster.
sourceKafkaClusterId String: The ID of the source Kafka cluster.
targetKafkaClusterArn String: Amazon Resource Name of the target Kafka cluster.
targetKafkaClusterId String: The ID of the target Kafka cluster.

ReplicatorReplicationInfoTargetCompressionType, ReplicatorReplicationInfoTargetCompressionTypeArgs

None: NONE
Gzip: GZIP
Snappy: SNAPPY
Lz4: LZ4
Zstd: ZSTD

ReplicatorReplicationInfoTargetCompressionTypeNone: NONE
ReplicatorReplicationInfoTargetCompressionTypeGzip: GZIP
ReplicatorReplicationInfoTargetCompressionTypeSnappy: SNAPPY
ReplicatorReplicationInfoTargetCompressionTypeLz4: LZ4
ReplicatorReplicationInfoTargetCompressionTypeZstd: ZSTD

None: NONE
Gzip: GZIP
Snappy: SNAPPY
Lz4: LZ4
Zstd: ZSTD

None: NONE
Gzip: GZIP
Snappy: SNAPPY
Lz4: LZ4
Zstd: ZSTD

NONE: NONE
GZIP: GZIP
SNAPPY: SNAPPY
LZ4: LZ4
ZSTD: ZSTD

"NONE": NONE
"GZIP": GZIP
"SNAPPY": SNAPPY
"LZ4": LZ4
"ZSTD": ZSTD

ReplicatorReplicationStartingPosition, ReplicatorReplicationStartingPositionArgs

Configuration for specifying the position in the topics to start replicating from.

Type Pulumi.AwsNative.Msk.ReplicatorReplicationStartingPositionType: The type of replication starting position.

Type ReplicatorReplicationStartingPositionType: The type of replication starting position.

type ReplicatorReplicationStartingPositionType: The type of replication starting position.

type ReplicatorReplicationStartingPositionType: The type of replication starting position.

type ReplicatorReplicationStartingPositionType: The type of replication starting position.

type "LATEST" | "EARLIEST": The type of replication starting position.

ReplicatorReplicationStartingPositionType, ReplicatorReplicationStartingPositionTypeArgs

Latest: LATEST
Earliest: EARLIEST

ReplicatorReplicationStartingPositionTypeLatest: LATEST
ReplicatorReplicationStartingPositionTypeEarliest: EARLIEST

Latest: LATEST
Earliest: EARLIEST

Latest: LATEST
Earliest: EARLIEST

LATEST: LATEST
EARLIEST: EARLIEST

"LATEST": LATEST
"EARLIEST": EARLIEST

ReplicatorReplicationTopicNameConfiguration, ReplicatorReplicationTopicNameConfigurationArgs

Configuration for specifying replicated topic names should be the same as their corresponding upstream topics or prefixed with source cluster alias.

Type Pulumi.AwsNative.Msk.ReplicatorReplicationTopicNameConfigurationType: The type of replication topic name configuration, identical to upstream topic name or prefixed with source cluster alias.

Type ReplicatorReplicationTopicNameConfigurationType: The type of replication topic name configuration, identical to upstream topic name or prefixed with source cluster alias.

type ReplicatorReplicationTopicNameConfigurationType: The type of replication topic name configuration, identical to upstream topic name or prefixed with source cluster alias.

type ReplicatorReplicationTopicNameConfigurationType: The type of replication topic name configuration, identical to upstream topic name or prefixed with source cluster alias.

type ReplicatorReplicationTopicNameConfigurationType: The type of replication topic name configuration, identical to upstream topic name or prefixed with source cluster alias.

type "PREFIXED_WITH_SOURCE_CLUSTER_ALIAS" | "IDENTICAL": The type of replication topic name configuration, identical to upstream topic name or prefixed with source cluster alias.

ReplicatorReplicationTopicNameConfigurationType, ReplicatorReplicationTopicNameConfigurationTypeArgs

PrefixedWithSourceClusterAlias: PREFIXED_WITH_SOURCE_CLUSTER_ALIAS
Identical: IDENTICAL

ReplicatorReplicationTopicNameConfigurationTypePrefixedWithSourceClusterAlias: PREFIXED_WITH_SOURCE_CLUSTER_ALIAS
ReplicatorReplicationTopicNameConfigurationTypeIdentical: IDENTICAL

PrefixedWithSourceClusterAlias: PREFIXED_WITH_SOURCE_CLUSTER_ALIAS
Identical: IDENTICAL

PrefixedWithSourceClusterAlias: PREFIXED_WITH_SOURCE_CLUSTER_ALIAS
Identical: IDENTICAL

PREFIXED_WITH_SOURCE_CLUSTER_ALIAS: PREFIXED_WITH_SOURCE_CLUSTER_ALIAS
IDENTICAL: IDENTICAL

"PREFIXED_WITH_SOURCE_CLUSTER_ALIAS": PREFIXED_WITH_SOURCE_CLUSTER_ALIAS
"IDENTICAL": IDENTICAL

ReplicatorS3, ReplicatorS3Args

Details about delivering logs to S3.

Enabled bool: Whether log delivery to S3 is enabled.
Bucket string: The S3 bucket that is the destination for log delivery.
Prefix string: The S3 prefix that is the destination for log delivery.

Enabled bool: Whether log delivery to S3 is enabled.
Bucket string: The S3 bucket that is the destination for log delivery.
Prefix string: The S3 prefix that is the destination for log delivery.

enabled Boolean: Whether log delivery to S3 is enabled.
bucket String: The S3 bucket that is the destination for log delivery.
prefix String: The S3 prefix that is the destination for log delivery.

enabled boolean: Whether log delivery to S3 is enabled.
bucket string: The S3 bucket that is the destination for log delivery.
prefix string: The S3 prefix that is the destination for log delivery.

enabled bool: Whether log delivery to S3 is enabled.
bucket str: The S3 bucket that is the destination for log delivery.
prefix str: The S3 prefix that is the destination for log delivery.

enabled Boolean: Whether log delivery to S3 is enabled.
bucket String: The S3 bucket that is the destination for log delivery.
prefix String: The S3 prefix that is the destination for log delivery.

ReplicatorTopicReplication, ReplicatorTopicReplicationArgs

TopicsToReplicate List<string>: List of regular expression patterns indicating the topics to copy.
CopyAccessControlListsForTopics bool: Whether to periodically configure remote topic ACLs to match their corresponding upstream topics.
CopyTopicConfigurations bool: Whether to periodically configure remote topics to match their corresponding upstream topics.
DetectAndCopyNewTopics bool: Whether to periodically check for new topics and partitions.
StartingPosition Pulumi.AwsNative.Msk.Inputs.ReplicatorReplicationStartingPosition: Configuration for specifying the position in the topics to start replicating from.
TopicNameConfiguration Pulumi.AwsNative.Msk.Inputs.ReplicatorReplicationTopicNameConfiguration: Configuration for specifying replicated topic names should be the same as their corresponding upstream topics or prefixed with source cluster alias.
TopicsToExclude List<string>: List of regular expression patterns indicating the topics that should not be replicated.

TopicsToReplicate []string: List of regular expression patterns indicating the topics to copy.
CopyAccessControlListsForTopics bool: Whether to periodically configure remote topic ACLs to match their corresponding upstream topics.
CopyTopicConfigurations bool: Whether to periodically configure remote topics to match their corresponding upstream topics.
DetectAndCopyNewTopics bool: Whether to periodically check for new topics and partitions.
StartingPosition ReplicatorReplicationStartingPosition: Configuration for specifying the position in the topics to start replicating from.
TopicNameConfiguration ReplicatorReplicationTopicNameConfiguration: Configuration for specifying replicated topic names should be the same as their corresponding upstream topics or prefixed with source cluster alias.
TopicsToExclude []string: List of regular expression patterns indicating the topics that should not be replicated.

topicsToReplicate List<String>: List of regular expression patterns indicating the topics to copy.
copyAccessControlListsForTopics Boolean: Whether to periodically configure remote topic ACLs to match their corresponding upstream topics.
copyTopicConfigurations Boolean: Whether to periodically configure remote topics to match their corresponding upstream topics.
detectAndCopyNewTopics Boolean: Whether to periodically check for new topics and partitions.
startingPosition ReplicatorReplicationStartingPosition: Configuration for specifying the position in the topics to start replicating from.
topicNameConfiguration ReplicatorReplicationTopicNameConfiguration: Configuration for specifying replicated topic names should be the same as their corresponding upstream topics or prefixed with source cluster alias.
topicsToExclude List<String>: List of regular expression patterns indicating the topics that should not be replicated.

topicsToReplicate string[]: List of regular expression patterns indicating the topics to copy.
copyAccessControlListsForTopics boolean: Whether to periodically configure remote topic ACLs to match their corresponding upstream topics.
copyTopicConfigurations boolean: Whether to periodically configure remote topics to match their corresponding upstream topics.
detectAndCopyNewTopics boolean: Whether to periodically check for new topics and partitions.
startingPosition ReplicatorReplicationStartingPosition: Configuration for specifying the position in the topics to start replicating from.
topicNameConfiguration ReplicatorReplicationTopicNameConfiguration: Configuration for specifying replicated topic names should be the same as their corresponding upstream topics or prefixed with source cluster alias.
topicsToExclude string[]: List of regular expression patterns indicating the topics that should not be replicated.

topics_to_replicate Sequence[str]: List of regular expression patterns indicating the topics to copy.
copy_access_control_lists_for_topics bool: Whether to periodically configure remote topic ACLs to match their corresponding upstream topics.
copy_topic_configurations bool: Whether to periodically configure remote topics to match their corresponding upstream topics.
detect_and_copy_new_topics bool: Whether to periodically check for new topics and partitions.
starting_position ReplicatorReplicationStartingPosition: Configuration for specifying the position in the topics to start replicating from.
topic_name_configuration ReplicatorReplicationTopicNameConfiguration: Configuration for specifying replicated topic names should be the same as their corresponding upstream topics or prefixed with source cluster alias.
topics_to_exclude Sequence[str]: List of regular expression patterns indicating the topics that should not be replicated.

topicsToReplicate List<String>: List of regular expression patterns indicating the topics to copy.
copyAccessControlListsForTopics Boolean: Whether to periodically configure remote topic ACLs to match their corresponding upstream topics.
copyTopicConfigurations Boolean: Whether to periodically configure remote topics to match their corresponding upstream topics.
detectAndCopyNewTopics Boolean: Whether to periodically check for new topics and partitions.
startingPosition Property Map: Configuration for specifying the position in the topics to start replicating from.
topicNameConfiguration Property Map: Configuration for specifying replicated topic names should be the same as their corresponding upstream topics or prefixed with source cluster alias.
topicsToExclude List<String>: List of regular expression patterns indicating the topics that should not be replicated.

Tag, TagArgs

A set of tags to apply to the resource.

Key string: The key name of the tag
Value string: The value of the tag

Key string: The key name of the tag
Value string: The value of the tag

key String: The key name of the tag
value String: The value of the tag

key string: The key name of the tag
value string: The value of the tag

key str: The key name of the tag
value str: The value of the tag

key String: The key name of the tag
value String: The value of the tag

Package Details

Repository: AWS Native pulumi/pulumi-aws-native
License: Apache-2.0

We recommend new projects start with resources from the AWS provider.

Viewing docs for AWS Cloud Control v1.63.0
published on Monday, May 4, 2026 by Pulumi

Schema (JSON)

pulumi/pulumi-aws-native

aws-native.msk.Replicator

On this page

On this page

Create Replicator Resource

Constructor syntax

Parameters

Replicator Resource Properties

Inputs

Outputs

Supporting Types

LogDelivery, LogDeliveryArgs

ReplicatorAmazonMskCluster, ReplicatorAmazonMskClusterArgs

ReplicatorApacheKafkaCluster, ReplicatorApacheKafkaClusterArgs

ReplicatorCloudWatchLogs, ReplicatorCloudWatchLogsArgs

ReplicatorConsumerGroupOffsetSyncMode, ReplicatorConsumerGroupOffsetSyncModeArgs

ReplicatorConsumerGroupReplication, ReplicatorConsumerGroupReplicationArgs

ReplicatorFirehose, ReplicatorFirehoseArgs

ReplicatorKafkaCluster, ReplicatorKafkaClusterArgs

ReplicatorKafkaClusterClientAuthentication, ReplicatorKafkaClusterClientAuthenticationArgs

ReplicatorKafkaClusterClientVpcConfig, ReplicatorKafkaClusterClientVpcConfigArgs

ReplicatorKafkaClusterEncryptionInTransit, ReplicatorKafkaClusterEncryptionInTransitArgs

ReplicatorKafkaClusterEncryptionInTransitType, ReplicatorKafkaClusterEncryptionInTransitTypeArgs

ReplicatorKafkaClusterSaslScramAuthentication, ReplicatorKafkaClusterSaslScramAuthenticationArgs

ReplicatorKafkaClusterSaslScramMechanism, ReplicatorKafkaClusterSaslScramMechanismArgs

ReplicatorLogDelivery, ReplicatorLogDeliveryArgs

ReplicatorReplicationInfo, ReplicatorReplicationInfoArgs

ReplicatorReplicationInfoTargetCompressionType, ReplicatorReplicationInfoTargetCompressionTypeArgs

ReplicatorReplicationStartingPosition, ReplicatorReplicationStartingPositionArgs

ReplicatorReplicationStartingPositionType, ReplicatorReplicationStartingPositionTypeArgs

ReplicatorReplicationTopicNameConfiguration, ReplicatorReplicationTopicNameConfigurationArgs

ReplicatorReplicationTopicNameConfigurationType, ReplicatorReplicationTopicNameConfigurationTypeArgs

ReplicatorS3, ReplicatorS3Args

ReplicatorTopicReplication, ReplicatorTopicReplicationArgs

Tag, TagArgs

Package Details

On this page

On this page