Kafka / Client / describe_replicator

describe_replicator¶

Kafka.Client.describe_replicator(**kwargs)¶

Describes a replicator.

Request Syntax

response = client.describe_replicator(
    ReplicatorArn='string'
)

Parameters:

ReplicatorArn (string) –

[REQUIRED]

The Amazon Resource Name (ARN) of the replicator to be described.

Return type:

dict

Returns:

Response Syntax

{
    'CreationTime': datetime(2015, 1, 1),
    'CurrentVersion': 'string',
    'IsReplicatorReference': True|False,
    'KafkaClusters': [
        {
            'AmazonMskCluster': {
                'MskClusterArn': 'string'
            },
            'ApacheKafkaCluster': {
                'ApacheKafkaClusterId': 'string',
                'BootstrapBrokerString': 'string'
            },
            'KafkaClusterAlias': 'string',
            'VpcConfig': {
                'SecurityGroupIds': [
                    'string',
                ],
                'SubnetIds': [
                    'string',
                ]
            },
            'ClientAuthentication': {
                'SaslScram': {
                    'Mechanism': 'SHA256'|'SHA512',
                    'SecretArn': 'string'
                }
            },
            'EncryptionInTransit': {
                'EncryptionType': 'TLS',
                'RootCaCertificate': 'string'
            }
        },
    ],
    'ReplicationInfoList': [
        {
            'ConsumerGroupReplication': {
                'ConsumerGroupsToExclude': [
                    'string',
                ],
                'ConsumerGroupsToReplicate': [
                    'string',
                ],
                'DetectAndCopyNewConsumerGroups': True|False,
                'SynchroniseConsumerGroupOffsets': True|False,
                'ConsumerGroupOffsetSyncMode': 'LEGACY'|'ENHANCED'
            },
            'SourceKafkaClusterAlias': 'string',
            'TargetCompressionType': 'NONE'|'GZIP'|'SNAPPY'|'LZ4'|'ZSTD',
            'TargetKafkaClusterAlias': 'string',
            'TopicReplication': {
                'CopyAccessControlListsForTopics': True|False,
                'CopyTopicConfigurations': True|False,
                'DetectAndCopyNewTopics': True|False,
                'StartingPosition': {
                    'Type': 'LATEST'|'EARLIEST'
                },
                'TopicNameConfiguration': {
                    'Type': 'PREFIXED_WITH_SOURCE_CLUSTER_ALIAS'|'IDENTICAL'
                },
                'TopicsToExclude': [
                    'string',
                ],
                'TopicsToReplicate': [
                    'string',
                ]
            }
        },
    ],
    'ReplicatorArn': 'string',
    'ReplicatorDescription': 'string',
    'ReplicatorName': 'string',
    'ReplicatorResourceArn': 'string',
    'ReplicatorState': 'RUNNING'|'CREATING'|'UPDATING'|'DELETING'|'FAILED',
    'ServiceExecutionRoleArn': 'string',
    'StateInfo': {
        'Code': 'string',
        'Message': 'string'
    },
    'Tags': {
        'string': 'string'
    },
    'LogDelivery': {
        'ReplicatorLogDelivery': {
            'CloudWatchLogs': {
                'Enabled': True|False,
                'LogGroup': 'string'
            },
            'Firehose': {
                'Enabled': True|False,
                'DeliveryStream': 'string'
            },
            'S3': {
                'Enabled': True|False,
                'Bucket': 'string',
                'Prefix': 'string'
            }
        }
    }
}

Response Structure

(dict) –

HTTP Status Code 200: OK.
- CreationTime (datetime) –
  
  The time when the replicator was created.
- CurrentVersion (string) –
  
  The current version number of the replicator.
- IsReplicatorReference (boolean) –
  
  Whether this resource is a replicator reference.
- KafkaClusters (list) –
  
  Kafka Clusters used in setting up sources / targets for replication.
  - (dict) –
    
    Information about Kafka Cluster used as source / target for replication.
    - AmazonMskCluster (dict) –
      
      Details of an Amazon MSK Cluster.
      - MskClusterArn (string) –
        
        The Amazon Resource Name (ARN) of an Amazon MSK cluster.
    - ApacheKafkaCluster (dict) –
      
      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.
    - KafkaClusterAlias (string) –
      
      The alias of the Kafka cluster. Used to prefix names of replicated topics.
    - VpcConfig (dict) –
      
      Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.
      - SecurityGroupIds (list) –
        
        The security groups to attach to the ENIs for the broker nodes.
        
        (string) –
      - SubnetIds (list) –
        
        The list of subnets in the client VPC to connect to.
        
        (string) –
    - ClientAuthentication (dict) –
      
      Details of the client authentication used by the Apache Kafka cluster.
      - SaslScram (dict) –
        
        Details for SASL/SCRAM client authentication.
        
        Mechanism (string) –
        
        The SASL/SCRAM authentication mechanism.
        
        SecretArn (string) –
        
        The Amazon Resource Name (ARN) of the Secrets Manager secret.
    - EncryptionInTransit (dict) –
      
      Details of encryption in transit to the Apache Kafka cluster.
      - EncryptionType (string) –
        
        The type of encryption in transit to the Apache Kafka cluster.
      - RootCaCertificate (string) –
        
        The root CA certificate.
- ReplicationInfoList (list) –
  
  A list of replication configurations, where each configuration targets a given source cluster to target cluster replication flow.
  - (dict) –
    
    Specifies configuration for replication between a source and target Kafka cluster (sourceKafkaClusterAlias -> targetKafkaClusterAlias)
    - ConsumerGroupReplication (dict) –
      
      Configuration relating to consumer group replication.
      - ConsumerGroupsToExclude (list) –
        
        List of regular expression patterns indicating the consumer groups that should not be replicated.
        
        (string) –
      - ConsumerGroupsToReplicate (list) –
        
        List of regular expression patterns indicating the consumer groups to copy.
        
        (string) –
      - DetectAndCopyNewConsumerGroups (boolean) –
        
        Enables synchronization of consumer groups to target cluster.
      - SynchroniseConsumerGroupOffsets (boolean) –
        
        Enables synchronization of consumer group offsets to target cluster. The translated offsets will be written to topic __consumer_offsets.
      - ConsumerGroupOffsetSyncMode (string) –
        
        The consumer group offset synchronization mode. With LEGACY, offsets are synchronized when producers write to the source cluster. With ENHANCED, consumer offsets are synchronized regardless of producer location. ENHANCED requires a corresponding replicator that replicates data from the target cluster to the source cluster.
    - SourceKafkaClusterAlias (string) –
      
      The alias of the source Kafka cluster.
    - TargetCompressionType (string) –
      
      The compression type to use when producing records to target cluster.
    - TargetKafkaClusterAlias (string) –
      
      The alias of the target Kafka cluster.
    - TopicReplication (dict) –
      
      Configuration relating to topic replication.
      - 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 (dict) –
        
        Configuration for specifying the position in the topics to start replicating from.
        
        Type (string) –
        
        The type of replication starting position.
      - TopicNameConfiguration (dict) –
        
        Configuration for specifying replicated topic names should be the same as their corresponding upstream topics or prefixed with source cluster alias.
        
        Type (string) –
        
        The type of replicated topic name.
      - TopicsToExclude (list) –
        
        List of regular expression patterns indicating the topics that should not be replicated.
        
        (string) –
      - TopicsToReplicate (list) –
        
        List of regular expression patterns indicating the topics to copy.
        
        (string) –
- ReplicatorArn (string) –
  
  The Amazon Resource Name (ARN) of the replicator.
- ReplicatorDescription (string) –
  
  The description of the replicator.
- ReplicatorName (string) –
  
  The name of the replicator.
- ReplicatorResourceArn (string) –
  
  The Amazon Resource Name (ARN) of the replicator resource in the region where the replicator was created.
- ReplicatorState (string) –
  
  State of the replicator.
- ServiceExecutionRoleArn (string) –
  
  The Amazon Resource Name (ARN) of the IAM role used by the replicator to access resources in the customer’s account (e.g source and target clusters)
- StateInfo (dict) –
  
  Details about the state of the replicator.
  - Code (string) – Code that describes the current state of the replicator.
  - Message (string) – Message that describes the state of the replicator.
- Tags (dict) –
  
  List of tags attached to the Replicator.
  - (string) –
    - (string) –
- LogDelivery (dict) –
  
  Configuration for log delivery.
  - ReplicatorLogDelivery (dict) –
    
    Configuration for replicator log delivery.
    - CloudWatchLogs (dict) –
      
      Configuration for CloudWatch Logs delivery.
      - Enabled (boolean) –
        
        Whether log delivery to CloudWatch Logs is enabled.
      - LogGroup (string) –
        
        The CloudWatch log group that is the destination for log delivery.
    - Firehose (dict) –
      
      Configuration for Firehose delivery.
      - Enabled (boolean) –
        
        Whether log delivery to Firehose is enabled.
      - DeliveryStream (string) –
        
        The Firehose delivery stream that is the destination for log delivery.
    - S3 (dict) –
      
      Configuration for S3 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.

describe_replicator¶

Request Syntax

Response Syntax

Response Structure

Exceptions