package kafka

You can search for identifiers within the package.

in-package search v0.2.0

OCaml bindings for Kafka

Install

dune-project

Dependency

sha256=709c482a2477da1790e1e8393fcf3c614ce79a2e183e3ffad4d772f3aded3858

md5=49bb99a375ed791cc9700bac18001965

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