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

//! KIP-213 foreign-key join internals: byte codecs (`CombinedKey`,
//! `SubscriptionWrapper`, `SubscriptionResponseWrapper`, Murmur3-128) + the five
//! join processors. All byte formats are JVM-exact (pinned by the `--fkjoin`
//! capture in `tests/testdata/fk_join/behavior.json`).
pub(crate) mod combined_key;
pub(crate) mod murmur3;
pub(crate) mod processors;
pub(crate) mod subscription;
pub(crate) mod wrapper_serde;