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

//! Typed Processor API and the type-erased execution graph used by the runtime.

pub mod api;
pub mod erased;
pub(crate) mod factory;
pub mod fixed_key;
pub(crate) mod graph;
pub(crate) mod node;
pub mod punctuation;
pub mod record;
pub mod serde;

pub use api::{Processor, ProcessorContext, ProcessorSupplier};
pub use erased::ProcessorError;
pub use fixed_key::{
    FixedKeyProcessor, FixedKeyProcessorContext, FixedKeyProcessorSupplier, FixedKeyRecord,
};
pub use punctuation::{Cancellable, PunctuationType, Punctuator};
pub use record::{Record, RecordContext};
pub use serde::{
    BytesSerde, Consumed, DefaultSerde, I64Serde, Produced, Serde, SerdeError, StringSerde,
};