Quarkus 中的并发消费者

Question

有没有办法在尝试消费来自 Quarkus 的消息时管理并发消费者的并发性？

我正在寻找具有并发性的批处理，以便在几秒钟内处理多条消息。我之前在SpringBoot中尝试过同样的方法，效果很好。正在尝试寻找 Quarkus 是否更好的方法。

Answer 1

查看 SmallRye Reactive Messaging 教程和 Kafka Guide。

基本上，您可以以命令式或反应式方式进行批处理。

命令式：

@Incoming(“your-topic”)
public void handle(List<Message> messages)

反应方式：

@Incoming(“your-topic”)
public Uni<Void> handle(Multi<Message> messages)