package kafka

  1. Overview
  2. Docs

Module Kafka_helpers.Kafka_producerSource

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
Sourceval 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
Sourceval topic_sink : ?producer_props:(string * string) list -> ?topic_props:(string * string) list -> ?delivery_error_handler:(Kafka.partition * string) push_error_handler -> string -> (Kafka.partition * string, unit) sink