我使用micronaut应用程序接收和返回apachekafka的React类型。来自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) 
    );
}

是否有任何使用此方法的示例，在生产者端如何处理返回值？