Module `Kafka`Source

Sourcetype handler

Sourcetype topic

Sourcetype queue

Sourcetype partition = int

Sourcetype offset = int64

Sourcetype message =

Sourcetype msg_id = int

Sourcetype error =

Sourceexception Error of error * string

Sourceval new_consumer : (string * string) list -> handler

val new_producer : 
  ?delivery_callback:(msg_id -> error option -> unit) ->
  (string * string) list ->
  handler

Sourceval destroy_handler : handler -> unit

Sourceval handler_name : handler -> string

val new_topic : 
  ?partitioner_callback:(int -> string -> partition) ->
  handler ->
  string ->
  (string * string) list ->
  topic

Sourceval destroy_topic : topic -> unit

Sourceval topic_name : topic -> string

val produce : 
  topic ->
  partition ->
  ?key:string ->
  ?msg_id:msg_id ->
  string ->
  unit

Sourceval partition_unassigned : partition

Sourceval outq_len : handler -> int

Sourceval poll_events : ?timeout_ms:int -> handler -> int

Sourceval wait_delivery : ?timeout_ms:int -> ?max_outq_len:int -> handler -> unit

Wait that messages are delivered (waiting that less than max_outq_len messages are pending).

Sourceval consume_start : topic -> partition -> offset -> unit

Sourceval offset_beginning : offset

Sourceval offset_end : offset

Sourceval offset_stored : offset

Sourceval offset_tail : int -> offset

Sourceval consume_stop : topic -> partition -> unit

Sourceval consume : ?timeout_ms:int -> topic -> partition -> message

val consume_batch : 
  ?timeout_ms:int ->
  ?msg_count:int ->
  topic ->
  partition ->
  message list

Sourceval new_queue : handler -> queue

Sourceval destroy_queue : queue -> unit

Sourceval consume_start_queue : queue -> topic -> partition -> offset -> unit

Sourceval consume_queue : ?timeout_ms:int -> queue -> message

val consume_batch_queue : 
  ?timeout_ms:int ->
  ?msg_count:int ->
  queue ->
  message list

Sourceval store_offset : topic -> partition -> offset -> unit

Sourcemodule Metadata : sig ... end

val topic_metadata : 
  ?timeout_ms:int ->
  handler ->
  topic ->
  Metadata.topic_metadata

val local_topics_metadata : 
  ?timeout_ms:int ->
  handler ->
  Metadata.topic_metadata list

val all_topics_metadata : 
  ?timeout_ms:int ->
  handler ->
  Metadata.topic_metadata list

package kafka