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 Edit opam file Versions (3)

Authors

D

Didier Wenzek <didier.wenzek@acidalie.com>

Maintainers

D

Didier Wenzek <didier.wenzek@acidalie.com>

Sources

0.4.tar.gz

sha256=baf6b799d20221aaeb60e7e2cca0ce82a80980ca6d355bff20024fbaed5339a5

md5=2904b2cce3c2496054bb7c01003a65e3

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