6 个版本 (3 个重大更新)
| 0.5.0 | 2024 年 4 月 24 日 |
|---|---|
| 0.3.2 | 2023 年 11 月 19 日 |
| 0.3.1 | 2023 年 7 月 11 日 |
| 0.2.1 | 2023 年 5 月 7 日 |
| 0.1.0 | 2023 年 3 月 2 日 |
#1173 在 并发 中
每月 2,198 次下载
在 4 个 Crates 中使用 (直接使用 2 个)
110KB
2.5K SLoC
sea-streamer-kafka: Kafka / Redpanda 后端
这是 SeaStreamer 的 Kafka / Redpanda 后端实现。此 crate 提供了一个全面的类型系统，使得与 Kafka 的工作更加容易和安全。
首先，所有的 API（许多是同步的）都已被正确地包装为异步。方法也被标记为 &mut 以消除可能的竞态条件。
KafkaConsumerOptions 具有类型参数。
KafkaConsumer 允许您 seek 到特定时间点，rewind 到特定的偏移量，并 commit 已读取的消息。
KafkaProducer 允许您 await 发送 Receipt 或如果您不感兴趣，则丢弃它。您还可以刷新 Producer。
KafkaStreamer 允许您在 disconnect 时刷新所有生产者。
请参阅 测试 以了解流语义的示例。
此 crate 依赖于 rdkafka，它又依赖于 librdkafka-sys，而后者是 librdkafka 的包装器。
依赖项
~14–30MB
~459K SLoC