package kafka-eio

  1. Overview
  2. Docs
Eio-native Kafka client for OCaml 5, built on librdkafka

Install

dune-project
 Dependency

Authors

Maintainers

Sources

v0.1.1.tar.gz
md5=88c2b9c6d263a1eb114cc5d1b570288a
sha512=44f5395fcc58b8d4303bc0b36113a17193da3a1925125cb0742fabeb96f32eb6b243c98d2fde283b6c95872ff36ddbf96de6e98b7612799e2aefeb2f85a1db95

doc/kafka-eio.kafka/Kafka/index.html

Module KafkaSource

Kafka is the canonical entry point: open Kafka and use Kafka.Producer/Kafka.Consumer/Kafka.Error/Kafka.Security instead of the flat Kafka_producer/Kafka_consumer/Kafka_error/ Kafka_security module names those packages still export directly (kept for existing callers — this is a pure alias, not a rename). Kafka_raw is deliberately not aliased here: it is internal to kafka-eio-core and was never meant to be part of the public surface.

Sourcemodule Producer = Kafka_producer
Sourcemodule Consumer = Kafka_consumer
Sourcemodule Error = Kafka_error
Sourcemodule Security = Kafka_security