package kafka

You can search for identifiers within the package.

in-package search v0.2.0

kafka
- Kafka
  - Metadata
kafka.helpers
- Kafka_helpers
  - Kafka_consumer
  - Kafka_producer

Legend:
Library
Module
Module type
Parameter
Class
Class type

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

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

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