Module `Kafka_lwt`

val consume : ?⁠timeout_ms:int -> Kafka.topic -> Kafka.partition -> Kafka.message Lwt.t
val consume_queue : ?⁠timeout_ms:int -> Kafka.queue -> Kafka.message Lwt.t
val consume_batch : ?⁠timeout_ms:int -> ?⁠msg_count:int -> Kafka.topic -> Kafka.partition -> Kafka.message list Lwt.t
val consume_batch_queue : ?⁠timeout_ms:int -> ?⁠msg_count:int -> Kafka.queue -> Kafka.message list Lwt.t
val new_producer : ?⁠delivery_check_period_ms:int -> (string * string) list -> Kafka.handler
val produce : Kafka.topic -> Kafka.partition -> ?⁠key:string -> string -> unit Lwt.t
val wait_delivery : ?⁠timeout_ms:int -> ?⁠max_outq_len:int -> Kafka.handler -> unit Lwt.t: Wait that messages are delivered (waiting that less than max_outq_len messages are pending).