Struct GetConsumerOffsetCmd 

pub struct GetConsumerOffsetCmd { /* private fields */ }

Implementations

impl GetConsumerOffsetCmd

pub fn new( consumer_id: Identifier, stream_id: Identifier, topic_id: Identifier, partition_id: u32, kind: ConsumerKind, ) -> Self

pub fn get_consumer_info(&self) -> String

Trait Implementations

impl CliCommand for GetConsumerOffsetCmd

fn explain(&self) -> String

fn execute_cmd<'life0, 'life1, 'async_trait>( &'life0 mut self, client: &'life1 dyn Client, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn use_tracing(&self) -> bool

fn login_required(&self) -> bool

fn connection_required(&self) -> bool