crabka-client-streams 0.3.2

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
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

//! High-level KStream/KTable DSL.
//!
//! The DSL records a typed logical graph, optionally applies JVM-compatible
//! topology optimizations, and lowers to the Processor-API [`Topology`].
//!
//! [`Topology`]: crate::topology::Topology
pub(crate) mod builder;
pub mod config;
pub mod global_table;
pub(crate) mod graph;
pub mod kgrouped;
pub mod kstream;
pub mod ktable;
pub(crate) mod lower;
pub(crate) mod names;
pub(crate) mod optimizer;
pub(crate) mod processors;
pub mod session_windowed_kgrouped;
pub mod suppress;
pub mod windowed_kgrouped;
pub use builder::StreamsBuilder;
pub use config::{Grouped, Materialized, Repartitioned, StreamJoined};
pub use global_table::GlobalKTable;
pub use kgrouped::KGroupedStream;
pub use kstream::{BranchedStream, KStream};
pub use ktable::KTable;
pub use session_windowed_kgrouped::SessionWindowedKGroupedStream;
pub use suppress::{BufferConfig, Suppressed};
pub use windowed_kgrouped::TimeWindowedKGroupedStream;
pub mod windows;
pub use windows::{
    JoinWindows, SessionWindowedSerde, SessionWindows, TimeWindowedSerde, TimeWindows, Window,
    Windowed,
};