Concurrent Consumers in Quarkus

Question

Is there a way to manage concurrency for concurrent consumers while trying to consume messages from Quarkus?

I am looking for Batch Processing with concurrency to process several messages in seconds. I tried the same in SpringBoot earlier and it works ok. Trying to find a way if Quarkus is better.

Answer 1

Check the SmallRye Reactive Messaging tutorial and the Kafka Guide.

Basically, you can either do batch processing in an imperative or reactive way.

Imperative way:

@Incoming("your-topic")
public void handle(List<Message> messages) {
    // process
}

Reactive way:

@Incoming("your-topic")
public Uni<Void> handle(Multi<Message> messages) {
    // process
}