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_producer/index.html

Module `Kafka_helpers.Kafka_producer`Source

Sourcetype ('a, 'b) sink = unit -> ('a -> unit) * (unit -> 'b)

A sink is defined as a function used to open an output stream. This function returns a pair of functions (push,close) aimed to push data into the stream and to finally close the stream.

Sourcetype 'a iterable = ('a -> unit) -> unit

Sourceval stream_to : ('a, 'b) sink -> 'a iterable -> 'b

Sourcetype 'a push_error_handler = ('a -> unit) -> 'a -> exn -> unit

Sourceval retry_on_error : 'a push_error_handler

Sourceval raise_on_error : 'a push_error_handler

Source

val partition_sink : 
  ?producer_props:(string * string) list ->
  ?topic_props:(string * string) list ->
  ?delivery_error_handler:string push_error_handler ->
  string ->
  Kafka.partition ->
  (string, unit) sink