我正在研究micronaut的一些微服务功能，我想创建。一个微服务解码多播数据包（使用vertx），并将它们发送到本地消息代理。如果我选择使用micronaut，我意识到我将不得不改用Kafka，这很好。
我一直在读Kafka的文档，但我似乎错过了一个简单的拼图。我不知道如何（在我的例子中）创建一个多播消费者，然后通过micronaut发布给kafka。有可能这样做吗？