Quarkus Kafka in cli mode

Question

I would like to create a Quarkus app in CLI mode to fetch data from kafka and store it in batch in the DB (as a Poor man's Spark). Is it possible to somehow inject a Kafka consumer and manually decide (according to offset lag) to fetch the messages ?

Thnx

Answer 1

"bare-kafka" usage docs in CR: https://github.com/quarkusio/quarkus-quickstarts/pull/746/