Struct kafka::utils::TopicMessage
[−]
[src]
pub struct TopicMessage { pub topic: String, pub partition: i32, pub offset: i64, pub error: Option<Error>, pub message: Vec<u8>, }
Fields
topic: String
partition: i32
offset: i64
error: Option<Error>
message: Vec<u8>