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
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

//! 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 cogrouped;
pub mod config;
pub mod emit;
pub mod global_table;
pub(crate) mod graph;
pub mod kgrouped;
pub(crate) mod kgrouped_table;
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_cogrouped;
pub mod session_windowed_kgrouped;
pub mod sliding_windowed_cogrouped;
pub mod sliding_windowed_kgrouped;
pub mod suppress;
pub mod time_windowed_cogrouped;
pub mod windowed_kgrouped;
pub use builder::StreamsBuilder;
pub use cogrouped::CogroupedKStream;
pub use config::{Grouped, Joined, Materialized, Repartitioned, StreamJoined, VersionedConfig};
pub use emit::EmitStrategy;
pub use global_table::GlobalKTable;
pub use kgrouped::KGroupedStream;
pub use kgrouped_table::KGroupedTable;
pub use kstream::{BranchedStream, KStream};
pub use ktable::KTable;
pub use session_windowed_cogrouped::SessionWindowedCogroupedStream;
pub use session_windowed_kgrouped::SessionWindowedKGroupedStream;
pub use sliding_windowed_cogrouped::SlidingWindowedCogroupedStream;
pub use sliding_windowed_kgrouped::SlidingWindowedKGroupedStream;
pub use suppress::{BufferConfig, Suppressed};
pub use time_windowed_cogrouped::TimeWindowedCogroupedStream;
pub use windowed_kgrouped::TimeWindowedKGroupedStream;
pub mod windows;
pub use windows::{
    JoinWindows, SessionWindowedSerde, SessionWindows, SlidingWindows, TimeWindowedSerde,
    TimeWindows, Window, Windowed,
};