package kafka

You can search for identifiers within the package.

in-package search v0.2.0

OCaml bindings for Kafka

Install

sha256=baf6b799d20221aaeb60e7e2cca0ce82a80980ca6d355bff20024fbaed5339a5

md5=2904b2cce3c2496054bb7c01003a65e3

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