Replicator

AWS Cloud Control v1.79.0, Sep 14 26

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

Viewing docs for AWS Cloud Control v1.79.0
published on Monday, Sep 14, 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.79.0
published on Monday, Sep 14, 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.

resource "aws-native_msk_replicator" "name" {
    # resource properties
}

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

kafka_clusters list(object): Specifies a list of Kafka clusters which are targets of the replicator.
replication_info_list list(object): A list of replication configurations, where each configuration targets a given source cluster to target cluster replication flow.
service_execution_role_arn 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.
log_delivery object: Configuration for log delivery for the replicator.
replicator_name string: The name of the replicator.
tags list(object): 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.

current_version string: The current version of the MSK replicator.
id string: The provider-assigned unique ID for this managed resource.
replicator_arn 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.

replicator_log_delivery object: 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.

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

apache_kafka_cluster_id string: The ID of the Apache Kafka cluster.
bootstrap_broker_string 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 bool: Whether log delivery to CloudWatch Logs is enabled.
log_group 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

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

consumer_groups_to_replicate list(string): List of regular expression patterns indicating the consumer groups to copy.
consumer_group_offset_sync_mode "LEGACY" | "ENHANCED": The consumer group offset synchronization mode.
consumer_groups_to_exclude list(string): 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 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 bool: Whether log delivery to Firehose is enabled.
delivery_stream 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.

ReplicatorJwtSigningAlgorithm, ReplicatorJwtSigningAlgorithmArgs

Rs256: RS256
Es384: ES384

ReplicatorJwtSigningAlgorithmRs256: RS256
ReplicatorJwtSigningAlgorithmEs384: ES384

"RS256": RS256
"ES384": ES384

Rs256: RS256
Es384: ES384

Rs256: RS256
Es384: ES384

RS256: RS256
ES384: ES384

"RS256": RS256
"ES384": ES384

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.

amazon_msk_cluster object: Details of an Amazon MSK cluster.
apache_kafka_cluster object: Details of an Apache Kafka cluster.
client_authentication object: Details of the client authentication used by the Apache Kafka cluster.
encryption_in_transit object: Details of encryption in transit to the Apache Kafka cluster.
vpc_config object: 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.

Mtls Pulumi.AwsNative.Msk.Inputs.ReplicatorKafkaClusterMtlsAuthentication: Details for mTLS client authentication.
SaslOAuthBearer Pulumi.AwsNative.Msk.Inputs.ReplicatorKafkaClusterSaslOAuthBearerAuthentication: Details for client authentication using SASL/OAUTHBEARER.
SaslScram Pulumi.AwsNative.Msk.Inputs.ReplicatorKafkaClusterSaslScramAuthentication: Details for SASL/SCRAM client authentication.

Mtls ReplicatorKafkaClusterMtlsAuthentication: Details for mTLS client authentication.
SaslOAuthBearer ReplicatorKafkaClusterSaslOAuthBearerAuthentication: Details for client authentication using SASL/OAUTHBEARER.
SaslScram ReplicatorKafkaClusterSaslScramAuthentication: Details for SASL/SCRAM client authentication.

mtls object: Details for mTLS client authentication.
sasl_o_auth_bearer object: Details for client authentication using SASL/OAUTHBEARER.
sasl_scram object: Details for SASL/SCRAM client authentication.

mtls ReplicatorKafkaClusterMtlsAuthentication: Details for mTLS client authentication.
saslOAuthBearer ReplicatorKafkaClusterSaslOAuthBearerAuthentication: Details for client authentication using SASL/OAUTHBEARER.
saslScram ReplicatorKafkaClusterSaslScramAuthentication: Details for SASL/SCRAM client authentication.

mtls ReplicatorKafkaClusterMtlsAuthentication: Details for mTLS client authentication.
saslOAuthBearer ReplicatorKafkaClusterSaslOAuthBearerAuthentication: Details for client authentication using SASL/OAUTHBEARER.
saslScram ReplicatorKafkaClusterSaslScramAuthentication: Details for SASL/SCRAM client authentication.

mtls ReplicatorKafkaClusterMtlsAuthentication: Details for mTLS client authentication.
sasl_o_auth_bearer ReplicatorKafkaClusterSaslOAuthBearerAuthentication: Details for client authentication using SASL/OAUTHBEARER.
sasl_scram ReplicatorKafkaClusterSaslScramAuthentication: Details for SASL/SCRAM client authentication.

mtls Property Map: Details for mTLS client authentication.
saslOAuthBearer Property Map: Details for client authentication using SASL/OAUTHBEARER.
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.

subnet_ids list(string): The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.
security_group_ids 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 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.

encryption_type "TLS": The type of encryption in transit to the Apache Kafka cluster.
root_ca_certificate 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

"TLS": TLS

ReplicatorKafkaClusterMtlsAuthentication, ReplicatorKafkaClusterMtlsAuthenticationArgs

Details for mTLS client authentication.

SecretArn string: The Amazon Resource Name (ARN) of the Secrets Manager secret.

SecretArn string: The Amazon Resource Name (ARN) of the Secrets Manager secret.

secret_arn string: The Amazon Resource Name (ARN) of the Secrets Manager secret.

secretArn String: The Amazon Resource Name (ARN) of the Secrets Manager secret.

secretArn string: The Amazon Resource Name (ARN) of the Secrets Manager secret.

secret_arn str: The Amazon Resource Name (ARN) of the Secrets Manager secret.

secretArn String: The Amazon Resource Name (ARN) of the Secrets Manager secret.

ReplicatorKafkaClusterOAuthClientCredentials, ReplicatorKafkaClusterOAuthClientCredentialsArgs

Details for SASL/OAUTHBEARER using the standard client_credentials grant. The referenced secret must contain client_id and client_secret.

TokenRequestSecretArn string: Secrets Manager ARN of the secret containing the client_id and client_secret used to obtain an OAuth Bearer token via the client_credentials grant.

TokenRequestSecretArn string: Secrets Manager ARN of the secret containing the client_id and client_secret used to obtain an OAuth Bearer token via the client_credentials grant.

token_request_secret_arn string: Secrets Manager ARN of the secret containing the client_id and client_secret used to obtain an OAuth Bearer token via the client_credentials grant.

tokenRequestSecretArn String: Secrets Manager ARN of the secret containing the client_id and client_secret used to obtain an OAuth Bearer token via the client_credentials grant.

tokenRequestSecretArn string: Secrets Manager ARN of the secret containing the client_id and client_secret used to obtain an OAuth Bearer token via the client_credentials grant.

token_request_secret_arn str: Secrets Manager ARN of the secret containing the client_id and client_secret used to obtain an OAuth Bearer token via the client_credentials grant.

tokenRequestSecretArn String: Secrets Manager ARN of the secret containing the client_id and client_secret used to obtain an OAuth Bearer token via the client_credentials grant.

ReplicatorKafkaClusterOAuthClientCredentialsAssertion, ReplicatorKafkaClusterOAuthClientCredentialsAssertionArgs

Details for SASL/OAUTHBEARER using the client credentials grant with a JWT client assertion (RFC 7521/7523 Section 2.2). An STS-vended JWT is used as the client_assertion.

Audience string: The audience (aud claim) set in the STS JWT client assertion.
SigningAlgorithm Pulumi.AwsNative.Msk.ReplicatorJwtSigningAlgorithm: The algorithm used to sign the JWT client assertion.
TokenRequestSecretArn string: Optional Secrets Manager ARN for identity providers that require client_id as a form parameter alongside the JWT client assertion.

Audience string: The audience (aud claim) set in the STS JWT client assertion.
SigningAlgorithm ReplicatorJwtSigningAlgorithm: The algorithm used to sign the JWT client assertion.
TokenRequestSecretArn string: Optional Secrets Manager ARN for identity providers that require client_id as a form parameter alongside the JWT client assertion.

audience string: The audience (aud claim) set in the STS JWT client assertion.
signing_algorithm "RS256" | "ES384": The algorithm used to sign the JWT client assertion.
token_request_secret_arn string: Optional Secrets Manager ARN for identity providers that require client_id as a form parameter alongside the JWT client assertion.

audience String: The audience (aud claim) set in the STS JWT client assertion.
signingAlgorithm ReplicatorJwtSigningAlgorithm: The algorithm used to sign the JWT client assertion.
tokenRequestSecretArn String: Optional Secrets Manager ARN for identity providers that require client_id as a form parameter alongside the JWT client assertion.

audience string: The audience (aud claim) set in the STS JWT client assertion.
signingAlgorithm ReplicatorJwtSigningAlgorithm: The algorithm used to sign the JWT client assertion.
tokenRequestSecretArn string: Optional Secrets Manager ARN for identity providers that require client_id as a form parameter alongside the JWT client assertion.

audience str: The audience (aud claim) set in the STS JWT client assertion.
signing_algorithm ReplicatorJwtSigningAlgorithm: The algorithm used to sign the JWT client assertion.
token_request_secret_arn str: Optional Secrets Manager ARN for identity providers that require client_id as a form parameter alongside the JWT client assertion.

audience String: The audience (aud claim) set in the STS JWT client assertion.
signingAlgorithm "RS256" | "ES384": The algorithm used to sign the JWT client assertion.
tokenRequestSecretArn String: Optional Secrets Manager ARN for identity providers that require client_id as a form parameter alongside the JWT client assertion.

ReplicatorKafkaClusterOAuthIamJwtBearer, ReplicatorKafkaClusterOAuthIamJwtBearerArgs

Details for SASL/OAUTHBEARER using the JWT Bearer assertion grant (RFC 7523). An STS-vended JWT is used as the assertion.

Audience string: The audience (aud claim) set in the STS JWT assertion.
SigningAlgorithm Pulumi.AwsNative.Msk.ReplicatorJwtSigningAlgorithm: The algorithm used to sign the JWT assertion.
TokenRequestSecretArn string: Optional Secrets Manager ARN for identity providers that require client authentication alongside the JWT Bearer assertion.

Audience string: The audience (aud claim) set in the STS JWT assertion.
SigningAlgorithm ReplicatorJwtSigningAlgorithm: The algorithm used to sign the JWT assertion.
TokenRequestSecretArn string: Optional Secrets Manager ARN for identity providers that require client authentication alongside the JWT Bearer assertion.

audience string: The audience (aud claim) set in the STS JWT assertion.
signing_algorithm "RS256" | "ES384": The algorithm used to sign the JWT assertion.
token_request_secret_arn string: Optional Secrets Manager ARN for identity providers that require client authentication alongside the JWT Bearer assertion.

audience String: The audience (aud claim) set in the STS JWT assertion.
signingAlgorithm ReplicatorJwtSigningAlgorithm: The algorithm used to sign the JWT assertion.
tokenRequestSecretArn String: Optional Secrets Manager ARN for identity providers that require client authentication alongside the JWT Bearer assertion.

audience string: The audience (aud claim) set in the STS JWT assertion.
signingAlgorithm ReplicatorJwtSigningAlgorithm: The algorithm used to sign the JWT assertion.
tokenRequestSecretArn string: Optional Secrets Manager ARN for identity providers that require client authentication alongside the JWT Bearer assertion.

audience str: The audience (aud claim) set in the STS JWT assertion.
signing_algorithm ReplicatorJwtSigningAlgorithm: The algorithm used to sign the JWT assertion.
token_request_secret_arn str: Optional Secrets Manager ARN for identity providers that require client authentication alongside the JWT Bearer assertion.

audience String: The audience (aud claim) set in the STS JWT assertion.
signingAlgorithm "RS256" | "ES384": The algorithm used to sign the JWT assertion.
tokenRequestSecretArn String: Optional Secrets Manager ARN for identity providers that require client authentication alongside the JWT Bearer assertion.

ReplicatorKafkaClusterSaslOAuthBearerAuthentication, ReplicatorKafkaClusterSaslOAuthBearerAuthenticationArgs

Details for client authentication using SASL/OAUTHBEARER.

TokenEndpointAuthenticationMethod Pulumi.AwsNative.Msk.ReplicatorTokenEndpointAuthenticationMethod: How client credentials are sent to the identity provider (POST, BASIC, or NONE).
TokenEndpointUrl string: The HTTPS URL of the OAuth token endpoint that vends OAuth Bearer tokens per RFC 6749.
ClientCredentials Pulumi.AwsNative.Msk.Inputs.ReplicatorKafkaClusterOAuthClientCredentials: Details for SASL/OAUTHBEARER using standard client_credentials grant. Mutually exclusive with iamJwtBearer and clientCredentialsAssertion.
ClientCredentialsAssertion Pulumi.AwsNative.Msk.Inputs.ReplicatorKafkaClusterOAuthClientCredentialsAssertion: Details for SASL/OAUTHBEARER using client credentials grant with JWT client assertion (RFC 7521/7523). Mutually exclusive with clientCredentials and iamJwtBearer.
IamJwtBearer Pulumi.AwsNative.Msk.Inputs.ReplicatorKafkaClusterOAuthIamJwtBearer: Details for SASL/OAUTHBEARER using JWT Bearer assertion grant (RFC 7523). Mutually exclusive with clientCredentials and clientCredentialsAssertion.
Scope string: OAuth scope to request. Included in the token request if provided.
TokenEndpointTlsCertificateArn string: Secrets Manager ARN containing a custom CA certificate for the identity provider. Required only if the identity provider uses a private CA.

TokenEndpointAuthenticationMethod ReplicatorTokenEndpointAuthenticationMethod: How client credentials are sent to the identity provider (POST, BASIC, or NONE).
TokenEndpointUrl string: The HTTPS URL of the OAuth token endpoint that vends OAuth Bearer tokens per RFC 6749.
ClientCredentials ReplicatorKafkaClusterOAuthClientCredentials: Details for SASL/OAUTHBEARER using standard client_credentials grant. Mutually exclusive with iamJwtBearer and clientCredentialsAssertion.
ClientCredentialsAssertion ReplicatorKafkaClusterOAuthClientCredentialsAssertion: Details for SASL/OAUTHBEARER using client credentials grant with JWT client assertion (RFC 7521/7523). Mutually exclusive with clientCredentials and iamJwtBearer.
IamJwtBearer ReplicatorKafkaClusterOAuthIamJwtBearer: Details for SASL/OAUTHBEARER using JWT Bearer assertion grant (RFC 7523). Mutually exclusive with clientCredentials and clientCredentialsAssertion.
Scope string: OAuth scope to request. Included in the token request if provided.
TokenEndpointTlsCertificateArn string: Secrets Manager ARN containing a custom CA certificate for the identity provider. Required only if the identity provider uses a private CA.

token_endpoint_authentication_method "POST" | "BASIC" | "NONE": How client credentials are sent to the identity provider (POST, BASIC, or NONE).
token_endpoint_url string: The HTTPS URL of the OAuth token endpoint that vends OAuth Bearer tokens per RFC 6749.
client_credentials object: Details for SASL/OAUTHBEARER using standard client_credentials grant. Mutually exclusive with iamJwtBearer and clientCredentialsAssertion.
client_credentials_assertion object: Details for SASL/OAUTHBEARER using client credentials grant with JWT client assertion (RFC 7521/7523). Mutually exclusive with clientCredentials and iamJwtBearer.
iam_jwt_bearer object: Details for SASL/OAUTHBEARER using JWT Bearer assertion grant (RFC 7523). Mutually exclusive with clientCredentials and clientCredentialsAssertion.
scope string: OAuth scope to request. Included in the token request if provided.
token_endpoint_tls_certificate_arn string: Secrets Manager ARN containing a custom CA certificate for the identity provider. Required only if the identity provider uses a private CA.

tokenEndpointAuthenticationMethod ReplicatorTokenEndpointAuthenticationMethod: How client credentials are sent to the identity provider (POST, BASIC, or NONE).
tokenEndpointUrl String: The HTTPS URL of the OAuth token endpoint that vends OAuth Bearer tokens per RFC 6749.
clientCredentials ReplicatorKafkaClusterOAuthClientCredentials: Details for SASL/OAUTHBEARER using standard client_credentials grant. Mutually exclusive with iamJwtBearer and clientCredentialsAssertion.
clientCredentialsAssertion ReplicatorKafkaClusterOAuthClientCredentialsAssertion: Details for SASL/OAUTHBEARER using client credentials grant with JWT client assertion (RFC 7521/7523). Mutually exclusive with clientCredentials and iamJwtBearer.
iamJwtBearer ReplicatorKafkaClusterOAuthIamJwtBearer: Details for SASL/OAUTHBEARER using JWT Bearer assertion grant (RFC 7523). Mutually exclusive with clientCredentials and clientCredentialsAssertion.
scope String: OAuth scope to request. Included in the token request if provided.
tokenEndpointTlsCertificateArn String: Secrets Manager ARN containing a custom CA certificate for the identity provider. Required only if the identity provider uses a private CA.

tokenEndpointAuthenticationMethod ReplicatorTokenEndpointAuthenticationMethod: How client credentials are sent to the identity provider (POST, BASIC, or NONE).
tokenEndpointUrl string: The HTTPS URL of the OAuth token endpoint that vends OAuth Bearer tokens per RFC 6749.
clientCredentials ReplicatorKafkaClusterOAuthClientCredentials: Details for SASL/OAUTHBEARER using standard client_credentials grant. Mutually exclusive with iamJwtBearer and clientCredentialsAssertion.
clientCredentialsAssertion ReplicatorKafkaClusterOAuthClientCredentialsAssertion: Details for SASL/OAUTHBEARER using client credentials grant with JWT client assertion (RFC 7521/7523). Mutually exclusive with clientCredentials and iamJwtBearer.
iamJwtBearer ReplicatorKafkaClusterOAuthIamJwtBearer: Details for SASL/OAUTHBEARER using JWT Bearer assertion grant (RFC 7523). Mutually exclusive with clientCredentials and clientCredentialsAssertion.
scope string: OAuth scope to request. Included in the token request if provided.
tokenEndpointTlsCertificateArn string: Secrets Manager ARN containing a custom CA certificate for the identity provider. Required only if the identity provider uses a private CA.

token_endpoint_authentication_method ReplicatorTokenEndpointAuthenticationMethod: How client credentials are sent to the identity provider (POST, BASIC, or NONE).
token_endpoint_url str: The HTTPS URL of the OAuth token endpoint that vends OAuth Bearer tokens per RFC 6749.
client_credentials ReplicatorKafkaClusterOAuthClientCredentials: Details for SASL/OAUTHBEARER using standard client_credentials grant. Mutually exclusive with iamJwtBearer and clientCredentialsAssertion.
client_credentials_assertion ReplicatorKafkaClusterOAuthClientCredentialsAssertion: Details for SASL/OAUTHBEARER using client credentials grant with JWT client assertion (RFC 7521/7523). Mutually exclusive with clientCredentials and iamJwtBearer.
iam_jwt_bearer ReplicatorKafkaClusterOAuthIamJwtBearer: Details for SASL/OAUTHBEARER using JWT Bearer assertion grant (RFC 7523). Mutually exclusive with clientCredentials and clientCredentialsAssertion.
scope str: OAuth scope to request. Included in the token request if provided.
token_endpoint_tls_certificate_arn str: Secrets Manager ARN containing a custom CA certificate for the identity provider. Required only if the identity provider uses a private CA.

tokenEndpointAuthenticationMethod "POST" | "BASIC" | "NONE": How client credentials are sent to the identity provider (POST, BASIC, or NONE).
tokenEndpointUrl String: The HTTPS URL of the OAuth token endpoint that vends OAuth Bearer tokens per RFC 6749.
clientCredentials Property Map: Details for SASL/OAUTHBEARER using standard client_credentials grant. Mutually exclusive with iamJwtBearer and clientCredentialsAssertion.
clientCredentialsAssertion Property Map: Details for SASL/OAUTHBEARER using client credentials grant with JWT client assertion (RFC 7521/7523). Mutually exclusive with clientCredentials and iamJwtBearer.
iamJwtBearer Property Map: Details for SASL/OAUTHBEARER using JWT Bearer assertion grant (RFC 7523). Mutually exclusive with clientCredentials and clientCredentialsAssertion.
scope String: OAuth scope to request. Included in the token request if provided.
tokenEndpointTlsCertificateArn String: Secrets Manager ARN containing a custom CA certificate for the identity provider. Required only if the identity provider uses a private CA.

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 "SHA256" | "SHA512": The SASL/SCRAM authentication mechanism.
secret_arn 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

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

cloud_watch_logs object: Details of the CloudWatch Logs destination for replicator logs.
firehose object: Details of the Kinesis Data Firehose delivery stream that is the destination for replicator logs.
s3 object: 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.

consumer_group_replication object: Configuration relating to consumer group replication.
target_compression_type "NONE" | "GZIP" | "SNAPPY" | "LZ4" | "ZSTD": The type of compression to use writing records to target Kafka cluster.
topic_replication object: Configuration relating to topic replication.
source_kafka_cluster_arn string: Amazon Resource Name of the source Kafka cluster.
source_kafka_cluster_id string: The ID of the source Kafka cluster.
target_kafka_cluster_arn string: Amazon Resource Name of the target Kafka cluster.
target_kafka_cluster_id 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

"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 "LATEST" | "EARLIEST": 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

"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 "PREFIXED_WITH_SOURCE_CLUSTER_ALIAS" | "IDENTICAL": 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

"PREFIXED_WITH_SOURCE_CLUSTER_ALIAS": PREFIXED_WITH_SOURCE_CLUSTER_ALIAS
"IDENTICAL": 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 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.

ReplicatorTokenEndpointAuthenticationMethod, ReplicatorTokenEndpointAuthenticationMethodArgs

Post: POST
Basic: BASIC
None: NONE

ReplicatorTokenEndpointAuthenticationMethodPost: POST
ReplicatorTokenEndpointAuthenticationMethodBasic: BASIC
ReplicatorTokenEndpointAuthenticationMethodNone: NONE

"POST": POST
"BASIC": BASIC
"NONE": NONE

Post: POST
Basic: BASIC
None: NONE

Post: POST
Basic: BASIC
None: NONE

POST: POST
BASIC: BASIC
NONE: NONE

"POST": POST
"BASIC": BASIC
"NONE": NONE

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.

topics_to_replicate list(string): 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 object: Configuration for specifying the position in the topics to start replicating from.
topic_name_configuration object: Configuration for specifying replicated topic names should be the same as their corresponding upstream topics or prefixed with source cluster alias.
topics_to_exclude list(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 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.79.0
published on Monday, Sep 14, 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

ReplicatorJwtSigningAlgorithm, ReplicatorJwtSigningAlgorithmArgs

ReplicatorKafkaCluster, ReplicatorKafkaClusterArgs

ReplicatorKafkaClusterClientAuthentication, ReplicatorKafkaClusterClientAuthenticationArgs

ReplicatorKafkaClusterClientVpcConfig, ReplicatorKafkaClusterClientVpcConfigArgs

ReplicatorKafkaClusterEncryptionInTransit, ReplicatorKafkaClusterEncryptionInTransitArgs

ReplicatorKafkaClusterEncryptionInTransitType, ReplicatorKafkaClusterEncryptionInTransitTypeArgs

ReplicatorKafkaClusterMtlsAuthentication, ReplicatorKafkaClusterMtlsAuthenticationArgs

ReplicatorKafkaClusterOAuthClientCredentials, ReplicatorKafkaClusterOAuthClientCredentialsArgs

ReplicatorKafkaClusterOAuthClientCredentialsAssertion, ReplicatorKafkaClusterOAuthClientCredentialsAssertionArgs

ReplicatorKafkaClusterOAuthIamJwtBearer, ReplicatorKafkaClusterOAuthIamJwtBearerArgs

ReplicatorKafkaClusterSaslOAuthBearerAuthentication, ReplicatorKafkaClusterSaslOAuthBearerAuthenticationArgs

ReplicatorKafkaClusterSaslScramAuthentication, ReplicatorKafkaClusterSaslScramAuthenticationArgs

ReplicatorKafkaClusterSaslScramMechanism, ReplicatorKafkaClusterSaslScramMechanismArgs

ReplicatorLogDelivery, ReplicatorLogDeliveryArgs

ReplicatorReplicationInfo, ReplicatorReplicationInfoArgs

ReplicatorReplicationInfoTargetCompressionType, ReplicatorReplicationInfoTargetCompressionTypeArgs

ReplicatorReplicationStartingPosition, ReplicatorReplicationStartingPositionArgs

ReplicatorReplicationStartingPositionType, ReplicatorReplicationStartingPositionTypeArgs

ReplicatorReplicationTopicNameConfiguration, ReplicatorReplicationTopicNameConfigurationArgs

ReplicatorReplicationTopicNameConfigurationType, ReplicatorReplicationTopicNameConfigurationTypeArgs

ReplicatorS3, ReplicatorS3Args

ReplicatorTokenEndpointAuthenticationMethod, ReplicatorTokenEndpointAuthenticationMethodArgs

ReplicatorTopicReplication, ReplicatorTopicReplicationArgs

Tag, TagArgs

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.