package kafka_async

  1. Overview
  2. Docs
Legend:
Library
Module
Module type
Parameter
Class
Class type
type producer
type consumer
type 'a response = ('a, Kafka.error * string) Stdlib.result
val produce : producer -> Kafka.topic -> Kafka.partition -> ?key:string -> string -> unit response Async.Deferred.t
val new_producer : (string * string) list -> producer response
val new_consumer : (string * string) list -> consumer response
val new_topic : producer -> string -> (string * string) list -> Kafka.topic response
val consume : consumer -> topic:string -> Kafka.message Async.Pipe.Reader.t response
val destroy_consumer : consumer -> unit
val destroy_producer : producer -> unit
OCaml

Innovation. Community. Security.