Module `Kafka_helpers.Kafka_consumer`

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