kafkaesque 0.0.15

Kafka implementations in Rust (Unofficial)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use super::{
    lazy_broker_connection::LazyBrokerConnection, topic_leaders::TopicPartitionLeaders, Result,
};
use crate::{
    clients::ClientConfig,
    formats::Write,
    models::{PartitionId, TopicName},
};
use futures::executor::block_on;
use std::{collections::HashMap, sync::Arc};
use tokio::sync::RwLock;

/// Metadata client
#[derive(Debug, Clone)]
pub struct ProducerClient {
    leaders: TopicPartitionLeaders,
}

impl ProducerClient {
    pub async fn create(config: ClientConfig) -> Result<Self> {
        let leaders = TopicPartitionLeaders::create(config).await?;
        Ok(ProducerClient { leaders })
    }

    pub async fn produce() -> Result<()> {
        todo!()
    }
}