crabka-client-streams 0.3.6

KIP-1071 Kafka Streams rebalance-protocol 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

//! Broker-backed execution runtime for built streams topologies.

mod app;
pub(crate) mod clock;
pub(crate) mod eos;
pub(crate) mod global;
pub mod io;
mod io_broker;
pub(crate) mod iq;
mod iq_view;
pub mod iqv2;
mod task;
mod thread;

pub use app::{KafkaStreams, KafkaStreamsState};
pub use io::{FetchBatch, FetchedRec, IsolationLevel, OffsetStore, RecordFetcher, RecordProducer};
pub use iq_view::ReadOnlyKeyValueStore;
pub use iq_view::ReadOnlySessionStore;
pub use iq_view::ReadOnlyWindowStore;