Kafka_consumer (p.kafka.0.3.doc.kafka.helpers.Kafka_helpers.Kafka

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