package kafka_lwt

  1. Overview
  2. Docs
Legend:
Library
Module
Module type
Parameter
Class
Class type
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).

OCaml

Innovation. Community. Security.