Backend-agnostic streaming abstraction for reinhardt.

Features

• kafka — Kafka backend using rskafka (pure Rust, no C bindings)

The Kafka-backed TaskBackend lives in reinhardt-tasks behind its kafka-backend feature (not here).

Direct API

use reinhardt_streaming::kafka::{KafkaConfig, KafkaProducer};

let config = KafkaConfig::new(vec!["localhost:9092"]);
let producer = KafkaProducer::connect(&config).await?;
producer.send("orders", &order).await?;