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_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
sectionYPositions = computeSectionYPositions($el), 10)"
x-init="setTimeout(() => sectionYPositions = computeSectionYPositions($el), 10)"
>