代码之家 › 专栏 › 技术社区 › San Jaisy

接收和返回带有micronaut 2.1.3的apache kafka反应型

micronaut-kafka micronaut-rest micronaut apache-kafka java

0

San Jaisy · 技术社区 · 5 年前

我使用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) 
    );
}

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

0 回复 | 直到 5 年前

1

0

Brian 5 年前

在本例中,当返回被动类型时,Micronaut framework将创建对 Single<Product>

Product @Topic

要生成消息,请参阅此处: https://micronaut-projects.github.io/micronaut-kafka/latest/guide/#kafkaClient .