Skip to content

ReplicationInfo

Source code in docs_src/capo_kafka/types/replication_info.py
class ReplicationInfo(TypedDict, closed=True):
    consumer_group_replication: NotRequired[
        "capo_kafka.types.consumer_group_replication.ConsumerGroupReplication"
    ]
    """<p>Configuration relating to consumer group replication.</p>"""
    source_kafka_cluster_arn: NotRequired["capo_kafka.types.__string.__string"]
    """<p>The ARN of the source Kafka cluster.</p>"""
    source_kafka_cluster_id: NotRequired["capo_kafka.types.__string.__string"]
    """<p>The ID of the source Kafka cluster.</p>"""
    target_compression_type: NotRequired[
        "capo_kafka.types.target_compression_type.TargetCompressionType"
    ]
    """<p>The compression type to use when producing records to target cluster.</p>"""
    target_kafka_cluster_arn: NotRequired["capo_kafka.types.__string.__string"]
    """<p>The ARN of the target Kafka cluster.</p>"""
    target_kafka_cluster_id: NotRequired["capo_kafka.types.__string.__string"]
    """<p>The ID of the target Kafka cluster.</p>"""
    topic_replication: NotRequired[
        "capo_kafka.types.topic_replication.TopicReplication"
    ]
    """<p>Configuration relating to topic replication.</p>"""

consumer_group_replication instance-attribute

consumer_group_replication: NotRequired[ConsumerGroupReplication]

Configuration relating to consumer group replication.

source_kafka_cluster_arn instance-attribute

source_kafka_cluster_arn: NotRequired[__string]

The ARN of the source Kafka cluster.

source_kafka_cluster_id instance-attribute

source_kafka_cluster_id: NotRequired[__string]

The ID of the source Kafka cluster.

target_compression_type instance-attribute

target_compression_type: NotRequired[TargetCompressionType]

The compression type to use when producing records to target cluster.

target_kafka_cluster_arn instance-attribute

target_kafka_cluster_arn: NotRequired[__string]

The ARN of the target Kafka cluster.

target_kafka_cluster_id instance-attribute

target_kafka_cluster_id: NotRequired[__string]

The ID of the target Kafka cluster.

topic_replication instance-attribute

topic_replication: NotRequired[TopicReplication]

Configuration relating to topic replication.