kf-protocol 2.0.3

Native Rust implementation of kafka protocol
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

use kf_protocol::derive::KfDefault;

#[derive(KfDefault,Debug)]
struct TestRecord {
    value: i8,
    value2: i8,
    #[fluvio_kf(default = "4")]
    value3: i8,
    #[fluvio_kf(default = "-1" )]
    value4: i16
}



#[test]
fn test_default() {

    let record = TestRecord::default();
    assert_eq!(record.value3,4);
    assert_eq!(record.value4,-1);
 


}