crabka-client-streams 0.3.0

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

//! Concrete `Processor` impls the DSL lowering attaches to the Processor-API
//! `Topology`. Each op's lowering thunk constructs one of these, capturing the
//! user closure; the four KV type parameters are inferred from the impl.
pub(crate) mod aggregate;
pub(crate) mod change;
pub(crate) mod global_join;
pub(crate) mod join;
pub(crate) mod ktable_join;
pub(crate) mod outer_join_store;
pub(crate) mod session_aggregate;
pub(crate) mod stateless;
pub(crate) mod stream_join;
pub(crate) mod suppress;
pub(crate) mod table;
pub(crate) mod window_aggregate;