Kafka_lwt (p.kafka.0.3.doc.kafka.lwt.Kafka

val consume : 
  ?timeout_ms:int ->
  Kafka.topic ->
  Kafka.partition ->
  Kafka.message Lwt.t

Sourceval 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).