package kafka

You can search for identifiers within the package.

in-package search v0.2.0

OCaml bindings for Kafka

Install

Dune Dependency

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

Authors

D

Didier Wenzek <didier.wenzek@acidalie.com>

Maintainers

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_consumer`Source

Source

val 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

Source

val 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

Source

val 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

package kafka

Install

Dune Dependency

Authors

Maintainers

Sources

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

Module Kafka_helpers.Kafka_consumerSource

Module `Kafka_helpers.Kafka_consumer`Source