java - 使用 micronaut 2.1.3 接收和返回 Reactive Types apache kafka

Question

我正在使用 Micronaut 应用程序通过 apache Kafka 接收和返回反应类型。来自 Micronaut 文档https://micronaut-projects.github.io/micronaut-kafka/latest/guide/

有一种接收和返回反应类型的方法，如下所示

此方法在消费者（侦听器端）

@Topic("reactive-products")
public Single<Product> receive(
        @KafkaKey String brand,  
        Single<Product> productFlowable) { 
    return productFlowable.doOnSuccess((product) ->
            System.out.println("Got Product - " + product.getName() + " by " + brand) 
    );
}

有没有使用这个方法的例子，返回值在Producer端会如何处理？

Answer 1

在此示例中，当返回反应类型时，Micronaut 框架创建对Single<Product>.

您不会编写任何代码来“使用”上述方法，因为这是由框架处理的。Product上面的代码是一个 kafka 消费者实现，当从 kafka 代理获取配置的消费者记录时，将接收实例@Topic。

生成消息可以参考这里：https ://micronaut-projects.github.io/micronaut-kafka/latest/guide/#kafkaClient 。