crabka-client-consumer 0.3.1

Subscribe-style consumer client for Apache Kafka in Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

//! KIP-932 share-group consumer client.
//!
//! A [`ShareConsumer`] joins a *share group* via `ShareGroupHeartbeat`
//! (API key 76) and — unlike the classic [`Consumer`](crate::Consumer) — does
//! not own partitions exclusively. The broker assigns the *same* partitions to
//! multiple members of the group; records are acquired (not assigned) per
//! `ShareFetch` and acknowledged individually (KIP-932 queues).
//!
//! Membership runs over a `ShareGroupHeartbeat` join + background heartbeat loop
//! that tracks the member epoch and live assignment; `poll()` issues
//! `ShareFetch` over the live assignment and acknowledgement (implicit/explicit)
//! is carried back via `ShareFetch` piggyback or a standalone
//! `ShareAcknowledge`.

mod consumer;
mod coordinator;
mod poll;
mod types;

pub use consumer::ShareConsumer;
pub use types::{ShareAckMode, ShareAckType, ShareConsumerRecord};