Apache骆驼设置并行消费

我有这条路线:

@Component
public class MyRoute implements RouteBuilder {

 @Override
 public void configure() {
        from(topic)
        .routeId(routeId)
        .process(exchange -> {
                // do something
        }
        .process(exchange -> {
                // do something
        }
        .to(anotherTopic);
    }

}

我想并行而不是顺序地处理来自主题的更多消息。

消息从kafka队列中使用,并且必须是事务性的。

我该怎么办?

wb214427411 回答:Apache骆驼设置并行消费

处理这种情况的一种通用方法是拆分路线并使用SEDA Component及其concurrentConsumers选项。

根据您的消息,具有parallelProcessing()功能的Split EIP可能也可以工作。

编辑:我发现《骆驼在行动》一书的第13章可以在线免费获得参考。 This link可能也有帮助

本文链接:https://www.f2er.com/3124861.html

大家都在问