package kafka

  1. Overview
  2. Docs
OCaml bindings for Kafka

Install 

dune-project
 Dependency

github.com Readme Changelog Edit opam file Versions (3)

Authors

  1. D
    Didier Wenzek <didier.wenzek@acidalie.com>

Maintainers

  1. D
    Didier Wenzek <didier.wenzek@acidalie.com>

Sources

kafka-0.5.tbz
sha256=7ec32681c104062a4fad43e2736e206128eb88273118071a044081abbc082255
sha512=7485d83cb20705f21b39c7e40cc6564cee30dba2c1993dc93c2791b4527488a33ef557e9fdaa47d3c0777986468f42460bb16c4d6d4076b1c43443f2cb5c6e3f

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