kwdowicz

use rdkafka::config::ClientConfig;
use rdkafka::consumer::{Consumer, StreamConsumer, CommitMode};
use rdkafka::message::{Message, BorrowedMessage};
use futures::stream::StreamExt; 
use tokio;  

#[tokio::main]  
async fn main() {
    let consumer: StreamConsumer = ClientConfig::new()
        .set("group.id", "test-group")

kwdowicz

use crate::Topping::{Ham, Pepper, Pineapple};

#[derive(Debug)]
enum Topping {
    Peperoni,
    Ham,
    Pineapple,
    Oregano,
    Pepper,
}