Module Kafka_async

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