package kafka_async

  1. Overview
  2. Docs
package kafka_async
Legend:
Library
Module
Module type
Parameter
Class
Class type
type producer
type consumer
type 'a response = ('a, Kafka.error * string) 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