Kafka Streams-style stream processing
Kafka Streams tarzΔ± stream iΕleme
Kafka istemci
rdkafka = "0.36"Async runtime
tokio = { version = "1", features = ["full"] }Serializasyon
serde = { version = "1", features = ["derive"] }Copy this Cargo.toml to get started:
[package]
name = "my-stream-processor"
version = "0.1.0"
edition = "2021"
[dependencies]
rdkafka = "0.36"
tokio = { version = "1", features = ["full"] }
serde = { version = "1", features = ["derive"] }
thiserror = "1"
tracing = "0.1"Learn these patterns to build this project effectively: