Junit Testing a Kafka Consumer

Hi everyone, I’m writing here hoping someone can give me an input or help on how to solve a small problem: I made a spring boot Java application that hosts a Kafka consumer that should read and process messages from a remote Kafka Producer. I’m having problems with testing: I wrote a simple test using EmbeddedKafkaBroker, I created a test producer and sent a message, but my KafkaListener doesn’t get triggered, so the test fails every time. Is there a way to test my Kafka consumer so I can ensure the test code coverage? I’d like my “fake” testProducer to trigger my “real” Kafka Consumer from inside the testing class and process the messages.
Thanks in advance to everyone!