samsa 0.1.8

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

use serde_derive::{Deserialize, Serialize};

#[derive(Debug, Deserialize, Serialize)]
pub struct PartitionTransformStatus {
    pub node_id: i32,
    pub partition: i32,
    pub status: String,
    pub lag: i32,
}