sea-streamer-kafka

Crates.iosea-streamer-kafka
lib.rssea-streamer-kafka
version0.5.0
sourcesrc
created_at2023-03-02 16:28:57.427236
updated_at2024-04-24 18:03:42.642535
description🌊 SeaStreamer Kafka / Redpanda Backend
homepage
repositoryhttps://github.com/SeaQL/sea-streamer
max_upload_size
id799000
size104,520
Chris Tsang (tyt2y3)

documentation

https://docs.rs/sea-streamer-kafka

README

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 disconnect.

See tests for an illustration of the stream semantics.

This crate depends on rdkafka, which in turn depends on librdkafka-sys, which itself is a wrapper of librdkafka.

Configuration Reference: https://kafka.apache.org/documentation/#configuration

Commit count: 344

cargo fmt