listener.java

@ApplicationScoped
@Slf4j
public class ListenerService
{
        @Incoming("in-topic")
        public void consumeMessage(String kafkaMessage)
        {
            log.info("Received message: {}", kafkaMessage);
            // Here you can process the kafkaMessage as needed
        }
}