Module MSK.Replicator

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-msk-replicator.html

type consumer_group_replication = {
  1. consumer_groups_to_replicate : string list;
  2. consumer_groups_to_exclude : string list option;
  3. synchronise_consumer_group_offsets : bool option;
  4. detect_and_copy_new_consumer_groups : bool option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-msk-replicator-consumergroupreplication.html

and tag = {
  1. value : string;
  2. key : string;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-resource-tags.html

and topic_replication = {
  1. topics_to_replicate : string list;
  2. topics_to_exclude : string list option;
  3. copy_topic_configurations : bool option;
  4. detect_and_copy_new_topics : bool option;
  5. copy_access_control_lists_for_topics : bool option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-msk-replicator-topicreplication.html

and kafka_cluster_client_vpc_config = {
  1. security_group_ids : string list option;
  2. subnet_ids : string list;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-msk-replicator-kafkaclusterclientvpcconfig.html

and amazon_msk_cluster = {
  1. msk_cluster_arn : string;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-msk-replicator-amazonmskcluster.html

and replication_info = {
  1. target_compression_type : string;
  2. topic_replication : topic_replication;
  3. consumer_group_replication : consumer_group_replication;
  4. source_kafka_cluster_arn : string;
  5. target_kafka_cluster_arn : string;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-msk-replicator-replicationinfo.html

and kafka_cluster = {
  1. vpc_config : kafka_cluster_client_vpc_config;
  2. amazon_msk_cluster : amazon_msk_cluster;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-msk-replicator-kafkacluster.html

type properties = {
  1. description : string option;
  2. current_version : string option;
  3. service_execution_role_arn : string;
  4. replicator_name : string;
  5. replication_info_list : replication_info list;
  6. kafka_clusters : kafka_cluster list;
  7. tags : tag list option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-msk-replicator.html;

val make_properties : ?description:string -> ?current_version:string -> service_execution_role_arn:string -> replicator_name:string -> replication_info_list:replication_info list -> kafka_clusters:kafka_cluster list -> ?tags:tag list -> unit -> properties
val make_consumer_group_replication : consumer_groups_to_replicate:string list -> ?consumer_groups_to_exclude:string list -> ?synchronise_consumer_group_offsets:bool -> ?detect_and_copy_new_consumer_groups:bool -> unit -> consumer_group_replication
val make_tag : value:string -> key:string -> unit -> tag
val make_topic_replication : topics_to_replicate:string list -> ?topics_to_exclude:string list -> ?copy_topic_configurations:bool -> ?detect_and_copy_new_topics:bool -> ?copy_access_control_lists_for_topics:bool -> unit -> topic_replication
val make_kafka_cluster_client_vpc_config : ?security_group_ids:string list -> subnet_ids:string list -> unit -> kafka_cluster_client_vpc_config
val make_amazon_msk_cluster : msk_cluster_arn:string -> unit -> amazon_msk_cluster
val make_replication_info : target_compression_type:string -> topic_replication:topic_replication -> consumer_group_replication:consumer_group_replication -> source_kafka_cluster_arn:string -> target_kafka_cluster_arn:string -> unit -> replication_info
val make_kafka_cluster : vpc_config:kafka_cluster_client_vpc_config -> amazon_msk_cluster:amazon_msk_cluster -> unit -> kafka_cluster
val yojson_of_consumer_group_replication : consumer_group_replication -> Yojson.Safe.t
val yojson_of_tag : tag -> [> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_topic_replication : topic_replication -> Yojson.Safe.t
val yojson_of_kafka_cluster_client_vpc_config : kafka_cluster_client_vpc_config -> [> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_amazon_msk_cluster : amazon_msk_cluster -> [> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_replication_info : replication_info -> [> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_kafka_cluster : kafka_cluster -> [> `Assoc of (string * [> `Assoc of (string * Yojson.Safe.t) list ]) list ]
val yojson_of_properties : properties -> [> `Assoc of (string * Yojson.Safe.t) list ]
type attributes = {
  1. ref_ : string;
  2. replicator_arn : string;
}
val create_attributes : string -> attributes
val cloudformation_type : string