什么版本的springcloudstream可以使用rxjava?

zqry0prt  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(160)

我使用SpringCloudStream/kafka构建了一个简单的SpringBoot项目,将输入和输出Map到rxjava可观察对象:

@StreamListener
@Output(Processor.OUTPUT)
public Observable<Response> processor(@Input(Processor.INPUT) Observable<Request> requests) {
    return requests.map(request -> {
        Response response = responseFactory().generateResponse(request);
        processContainer().process(request, response);
        return response;
    });
}

不过,我似乎只能使用camden sr1版本的spring云依赖。这意味着rxjava版本停留在1.1.10(由于rxjava库冲突,更高版本将不会运行)。

<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-dependencies</artifactId>
        <version>Camden.SR1</version>
        <type>pom</type>
        <scope>import</scope>
    </dependency>

我想我需要为zipkin sleuth使用更高版本的spring cloud:https://spring.io/blog/2016/02/15/distributed-tracing-with-spring-cloud-sleuth-and-spring-cloud-zipkin
有人知道springcloud的更高版本(brooklyn、chelsea、camden等)可以用rxjava编译和运行吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题