package kafka_async

You can search for identifiers within the package.

in-package search v0.2.0

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