Module KafkaConnect.Connector

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-kafkaconnect-connector.html

type worker_configuration = {
  1. revision : int;
  2. worker_configuration_arn : string;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kafkaconnect-connector-workerconfiguration.html

and s3_log_delivery = {
  1. bucket : string option;
  2. enabled : bool;
  3. prefix : string option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kafkaconnect-connector-s3logdelivery.html

and firehose_log_delivery = {
  1. delivery_stream : string option;
  2. enabled : bool;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kafkaconnect-connector-firehoselogdelivery.html

and kafka_cluster_encryption_in_transit = {
  1. encryption_type : string;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kafkaconnect-connector-kafkaclusterencryptionintransit.html

and scale_out_policy = {
  1. cpu_utilization_percentage : int;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kafkaconnect-connector-scaleoutpolicy.html

and cloud_watch_logs_log_delivery = {
  1. log_group : string option;
  2. enabled : bool;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kafkaconnect-connector-cloudwatchlogslogdelivery.html

and provisioned_capacity = {
  1. worker_count : int;
  2. mcu_count : int option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kafkaconnect-connector-provisionedcapacity.html

and vpc = {
  1. security_groups : string list;
  2. subnets : string list;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kafkaconnect-connector-vpc.html

and custom_plugin = {
  1. custom_plugin_arn : string;
  2. revision : int;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kafkaconnect-connector-customplugin.html

and kafka_cluster_client_authentication = {
  1. authentication_type : string;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kafkaconnect-connector-kafkaclusterclientauthentication.html

and scale_in_policy = {
  1. cpu_utilization_percentage : int;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kafkaconnect-connector-scaleinpolicy.html

and plugin = {
  1. custom_plugin : custom_plugin;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kafkaconnect-connector-plugin.html

and apache_kafka_cluster = {
  1. vpc : vpc;
  2. bootstrap_servers : string;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kafkaconnect-connector-apachekafkacluster.html

and worker_log_delivery = {
  1. s3 : s3_log_delivery option;
  2. firehose : firehose_log_delivery option;
  3. cloud_watch_logs : cloud_watch_logs_log_delivery option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kafkaconnect-connector-workerlogdelivery.html

and auto_scaling = {
  1. scale_out_policy : scale_out_policy;
  2. scale_in_policy : scale_in_policy;
  3. max_worker_count : int;
  4. min_worker_count : int;
  5. mcu_count : int;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kafkaconnect-connector-autoscaling.html

and log_delivery = {
  1. worker_log_delivery : worker_log_delivery;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kafkaconnect-connector-logdelivery.html

and kafka_cluster = {
  1. apache_kafka_cluster : apache_kafka_cluster;
}

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

and capacity = {
  1. provisioned_capacity : provisioned_capacity option;
  2. auto_scaling : auto_scaling option;
}

see http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kafkaconnect-connector-capacity.html

type properties = {
  1. kafka_cluster : kafka_cluster;
  2. kafka_connect_version : string;
  3. worker_configuration : worker_configuration option;
  4. capacity : capacity;
  5. kafka_cluster_encryption_in_transit : kafka_cluster_encryption_in_transit;
  6. connector_description : string option;
  7. kafka_cluster_client_authentication : kafka_cluster_client_authentication;
  8. connector_name : string;
  9. service_execution_role_arn : string;
  10. connector_configuration : string Stdlib__Map.Make(Stdlib.String).t;
  11. log_delivery : log_delivery option;
  12. plugins : plugin list;
}

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

val make_properties : kafka_cluster:kafka_cluster -> kafka_connect_version:string -> ?worker_configuration:worker_configuration -> capacity:capacity -> kafka_cluster_encryption_in_transit:kafka_cluster_encryption_in_transit -> ?connector_description:string -> kafka_cluster_client_authentication:kafka_cluster_client_authentication -> connector_name:string -> service_execution_role_arn:string -> connector_configuration:string Stdlib__Map.Make(Stdlib.String).t -> ?log_delivery:log_delivery -> plugins:plugin list -> unit -> properties
val make_worker_configuration : revision:int -> worker_configuration_arn:string -> unit -> worker_configuration
val make_s3_log_delivery : ?bucket:string -> enabled:bool -> ?prefix:string -> unit -> s3_log_delivery
val make_firehose_log_delivery : ?delivery_stream:string -> enabled:bool -> unit -> firehose_log_delivery
val make_kafka_cluster_encryption_in_transit : encryption_type:string -> unit -> kafka_cluster_encryption_in_transit
val make_scale_out_policy : cpu_utilization_percentage:int -> unit -> scale_out_policy
val make_cloud_watch_logs_log_delivery : ?log_group:string -> enabled:bool -> unit -> cloud_watch_logs_log_delivery
val make_provisioned_capacity : worker_count:int -> ?mcu_count:int -> unit -> provisioned_capacity
val make_vpc : security_groups:string list -> subnets:string list -> unit -> vpc
val make_custom_plugin : custom_plugin_arn:string -> revision:int -> unit -> custom_plugin
val make_kafka_cluster_client_authentication : authentication_type:string -> unit -> kafka_cluster_client_authentication
val make_scale_in_policy : cpu_utilization_percentage:int -> unit -> scale_in_policy
val make_plugin : custom_plugin:custom_plugin -> unit -> plugin
val make_apache_kafka_cluster : vpc:vpc -> bootstrap_servers:string -> unit -> apache_kafka_cluster
val make_worker_log_delivery : ?s3:s3_log_delivery -> ?firehose:firehose_log_delivery -> ?cloud_watch_logs:cloud_watch_logs_log_delivery -> unit -> worker_log_delivery
val make_auto_scaling : scale_out_policy:scale_out_policy -> scale_in_policy:scale_in_policy -> max_worker_count:int -> min_worker_count:int -> mcu_count:int -> unit -> auto_scaling
val make_log_delivery : worker_log_delivery:worker_log_delivery -> unit -> log_delivery
val make_kafka_cluster : apache_kafka_cluster:apache_kafka_cluster -> unit -> kafka_cluster
val make_capacity : ?provisioned_capacity:provisioned_capacity -> ?auto_scaling:auto_scaling -> unit -> capacity
val yojson_of_worker_configuration : worker_configuration -> [> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_s3_log_delivery : s3_log_delivery -> Yojson.Safe.t
val yojson_of_firehose_log_delivery : firehose_log_delivery -> Yojson.Safe.t
val yojson_of_kafka_cluster_encryption_in_transit : kafka_cluster_encryption_in_transit -> [> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_scale_out_policy : scale_out_policy -> Yojson.Safe.t
val yojson_of_cloud_watch_logs_log_delivery : cloud_watch_logs_log_delivery -> Yojson.Safe.t
val yojson_of_provisioned_capacity : provisioned_capacity -> Yojson.Safe.t
val yojson_of_vpc : vpc -> Yojson.Safe.t
val yojson_of_custom_plugin : custom_plugin -> [> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_kafka_cluster_client_authentication : kafka_cluster_client_authentication -> [> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_scale_in_policy : scale_in_policy -> Yojson.Safe.t
val yojson_of_plugin : plugin -> [> `Assoc of (string * [> `Assoc of (string * Yojson.Safe.t) list ]) list ]
val yojson_of_apache_kafka_cluster : apache_kafka_cluster -> [> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_worker_log_delivery : worker_log_delivery -> [> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_auto_scaling : auto_scaling -> Yojson.Safe.t
val yojson_of_log_delivery : log_delivery -> [> `Assoc of (string * [> `Assoc of (string * Yojson.Safe.t) list ]) list ]
val yojson_of_kafka_cluster : kafka_cluster -> [> `Assoc of (string * [> `Assoc of (string * Yojson.Safe.t) list ]) list ]
val yojson_of_capacity : capacity -> [> `Assoc of (string * Yojson.Safe.t) list ]
val yojson_of_properties : properties -> [> `Assoc of (string * Yojson.Safe.t) list ]
type attributes = {
  1. ref_ : string;
  2. connector_arn : string;
}
val create_attributes : string -> attributes
val cloudformation_type : string