4 releases (2 breaking)
|0.3.1||Jul 11, 2023|
|0.2.1||May 7, 2023|
|0.2.0||Mar 25, 2023|
|0.1.0||Mar 2, 2023|
#13 in #async-stream
111 downloads per month
Used in 3 crates (2 directly)
sea-streamer-kafka: Kafka / Redpanda Backend
This is the Kafka / Redpanda backend implementation for SeaStreamer. This crate provides a comprehensive type system that makes working with Kafka easier and safer.
First of all, all API (many are sync) are properly wrapped as async. Methods are also marked
&mut to eliminate possible race conditions.
KafkaConsumerOptions has typed parameters.
KafkaConsumer allows you to
seek to point in time,
rewind to particular offset, and
commit message read.
KafkaProducer allows you to
await a send
Receipt or discard it if you are uninterested. You can also flush the Producer.
KafkaStreamer allows you to flush all producers on
See tests for an illustration of the stream semantics.
Configuration Reference: https://kafka.apache.org/documentation/#configuration