samsa 0.1.8

Rust-native Kafka/Redpanda protocol and client implementation.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13

use serde_derive::{Deserialize, Serialize};

#[derive(Debug, Deserialize, Serialize)]
pub struct Partition {
    pub leader_id: i32,
    #[serde(alias = "ns")]
    pub namespace: String,
    pub partition_id: i32,
    pub raft_group_id: i32,
    // TODO replicas
    pub status: String,
    pub topic: String,
}