Is there a way to consume payloads from kafka without using @Incoming (Quarkus, smallrye, kafka)?

I'm creating a publish method using Emitter And I'm trying to create a unit test for this method. I don't want to use the InMemoryConnector (as described in the quarkus doc) I want to use the actual kafka connector configured in my appli

Continue reading →