package kafka

  1. Overview
  2. Docs
OCaml bindings for Kafka

Install

Dune Dependency

Authors

Maintainers

Sources

0.3.2.tar.gz
sha256=709c482a2477da1790e1e8393fcf3c614ce79a2e183e3ffad4d772f3aded3858
md5=49bb99a375ed791cc9700bac18001965

doc/kafka.helpers/Kafka_helpers/Kafka_consumer/index.html

Module Kafka_helpers.Kafka_consumerSource

Sourceval fold_partition : ?consumer_props:(string * string) list -> ?topic_props:(string * string) list -> ?timeout_ms:int -> ?stop_at_end:bool -> string -> Kafka.partition -> ('a -> Kafka.message -> 'a) -> Kafka.offset -> 'a -> 'a
Sourceval fold_topic : ?consumer_props:(string * string) list -> ?topic_props:(string * string) list -> ?timeout_ms:int -> ?stop_at_end:bool -> string -> Kafka.partition list -> ('a -> Kafka.message -> 'a) -> (Kafka.partition * Kafka.offset) list -> 'a -> 'a
Sourceval fold_queue : ?consumer_props:(string * string) list -> ?topic_props:(string * string) list -> ?timeout_ms:int -> ?stop_at_end:bool -> (string * Kafka.partition) list -> ('a -> Kafka.message -> 'a) -> (string * Kafka.partition * Kafka.offset) list -> 'a -> 'a
OCaml

Innovation. Community. Security.