package kafka
OCaml bindings for Kafka
Install
Dune Dependency
Authors
Maintainers
Sources
kafka-0.5.tbz
sha256=7ec32681c104062a4fad43e2736e206128eb88273118071a044081abbc082255
sha512=7485d83cb20705f21b39c7e40cc6564cee30dba2c1993dc93c2791b4527488a33ef557e9fdaa47d3c0777986468f42460bb16c4d6d4076b1c43443f2cb5c6e3f
doc/kafka.helpers/Kafka_helpers/Kafka_producer/index.html
Module Kafka_helpers.Kafka_producer
Source
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.
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
Source
val 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
sectionYPositions = computeSectionYPositions($el), 10)"
x-init="setTimeout(() => sectionYPositions = computeSectionYPositions($el), 10)"
>