pub trait IsOffset { // Required methods fn database(&self) -> &str; fn topic(&self) -> &str; fn vgroup_id(&self) -> VGroupId; }
Extract offset information.
Database name for current message
Topic name for current message.
VGroup id for current message.