Cannot get messages from kafka kraft although I can post

[jsoneaday]

I have a running instance of kafka with kraft. I can get back the partition and offset when doing a post to a topic. However I cannot consume on the same topic. This is my consumer code:

pub struct EventConsumer;

impl EventConsumer {
    fn create_consumer(group_id: &str) -> StreamConsumer {
        ClientConfig::new()
            .set("bootstrap.servers", format!(
                "{}:{}", 
                var("DEFAULT_KAFKA_HOST").unwrap_or(DEFAULT_KAFKA_HOST.to_string()), 
                var("DEFAULT_KAFKA_PORT").unwrap_or(DEFAULT_KAFKA_PORT.to_string())
            ))
            .set("group.id", group_id)
            .set("auto.offset.reset", "earliest")
            // .set("enable.partition.eof", "false")
            // .set("queued.min.messages", "1000")
            .create()
            .expect("Failed to connect to kafka")
    }

    pub async fn init_consumer(&self, topics: &[&str], group_id: &str) -> Result<(), Report<EventClientError>> {
        let consumer = Self::create_consumer(group_id);

        match consumer.subscribe(topics) {
            Ok(_) => {},
            Err(e) => {
                debug!("Consumer subscription attempt failed: {:?}", e);
                return Err(Report::new(EventClientError));
            }
        };

        loop {
            match consumer.recv().await {
                Ok(msg) => {
                    debug!("Got Consumer message: {:?}", msg);
                    if let Some(payload) = msg.payload() {
                        debug!("Message payload received: {:?}", payload);
                    } else {
                        debug!("Message payload is empty");
                    }
                },
                Err(e) => {
                    debug!("Receive kafka message error: {}", e);
                }
            }
        }    
        
    }
}