kafkang 0.3.0

Rust client for Apache Kafka
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

//! Some utility structures
//!
//! This module is _not_ exposed to the public directly.

/// A retrieved offset for a particular partition in the context of an
/// already known topic.
#[derive(Debug, Hash, PartialEq, Eq)]
pub struct PartitionOffset {
    pub offset: i64,
    pub partition: i32,
}

/// A retrieved offset for a particular partition in the context of an
/// already known topic, specific to a timestamp.
#[derive(Debug, Hash, PartialEq, Eq)]
pub struct TimestampedPartitionOffset {
    pub offset: i64,
    pub partition: i32,
    pub time: i64,
}