Kafka_async (p.kafka_async.0.5.doc.kafka_async.Kafka

Sourcetype producer

Sourcetype consumer

Sourcetype 'a response = ('a, Kafka.error * string) result

val produce : 
  producer ->
  Kafka.topic ->
  Kafka.partition ->
  ?key:string ->
  string ->
  unit response Async.Deferred.t

Sourceval new_producer : (string * string) list -> producer response

Sourceval 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

Sourceval destroy_consumer : consumer -> unit

Sourceval destroy_producer : producer -> unit