kacrab 0.1.0

A Kafka client for Rust, built from the protocol up.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! Shared Kafka-compatible domain types used across clients.
//!
//! These mirror the types Kafka places in `org.apache.kafka.common`
//! ([`TopicPartition`], [`OffsetAndMetadata`], [`ConsumerGroupMetadata`],
//! [`Node`]) and are always compiled, independent of the `producer`/`admin`
//! features, so every client surface can reuse them. The producer and admin
//! modules re-export the ones they expose at their original paths (e.g.
//! `kacrab::producer::TopicPartition`, `kacrab::admin::Node`) for backwards
//! compatibility.

mod consumer_group;
#[cfg(any(feature = "producer", feature = "admin"))]
mod coordinator;
mod node;
mod topic_partition;

#[cfg(any(feature = "producer", feature = "admin"))]
pub(crate) use self::coordinator::CoordinatorType;
pub use self::{
    consumer_group::ConsumerGroupMetadata,
    node::Node,
    topic_partition::{OffsetAndMetadata, TopicPartition},
};