我使用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编译和运行吗?
暂无答案!
目前还没有任何答案,快来回答吧!