Struct Consumer

pub struct Consumer { /* private fields */ }

A simple Franz Consumer that receives messages from the broker

use franz_client::{Consumer, FranzClientError};

fn main() -> Result<(), FranzClientError> {
    let mut consumer = Consumer::new("127.0.0.1:8085", "test", None)?;
    let msg = consumer.recv()?;
    Ok(println!("{}", String::from_utf8_lossy(&msg)))
}

Implementations

impl Consumer

pub fn new( broker: impl ToSocketAddrs, topic: &str, group: Option<u16>, ) -> Result<Self, FranzClientError>

pub fn recv(&mut self) -> Result<Vec<u8>, FranzClientError>