KafkaAction (p.awso.0.9.1.doc.awso.iot.Awso_iot.Values

Sourcetype nonrec t = {

destinationArn : AwsArn.t;
(*
The ARN of Kafka action's VPC TopicRuleDestination.
*)
topic : String_.t;
(*
The Kafka topic for messages to be sent to the Kafka broker.
*)
key : String_.t option;
(*
The Kafka message key.
*)
partition : String_.t option;
(*
The Kafka message partition.
*)
clientProperties : ClientProperties.t;
(*
Properties of the Apache Kafka producer client.
*)
headers : KafkaHeaders.t option;
(*
The list of Kafka headers that you specify.
*)

}

Sourceval context_ : string

val make : 
  ?key:??? ->
  ?partition:??? ->
  ?headers:??? ->
  destinationArn:AwsArn.t ->
  topic:String_.t ->
  clientProperties:ClientProperties.t ->
  unit ->
  t

Source

val to_value : 
  t ->
  [> `Structure of
       (string
        * [> `List of
               [> `Structure of
                    (string * [> `String of KafkaHeaderKey.t ]) list ]
                 list
          | `Map of
            ([> `String of String_.t ] * [> `String of String_.t ]) list
          | `String of AwsArn.t ])
         list ]

Sourceval to_query : t -> Awso.Client.Query.t

Sourceval of_xml : Awso.Xml.t -> t

Sourceval of_string : string -> t

Sourceval of_json : Yojson.Safe.t -> t

Sourceval to_json : t -> Yojson.Safe.t