java - Apache Camel设置并行消费

Question

我有这条路线:

@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队列中消费的，并且必须是事务性的。

我该怎么办？

Answer 1

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

根据您的消息，Split EIP其 parallelProcessing() 功能也可能有效。

编辑:我发现《Camel in Action》一书的第 13 章可以在网上免费引用。 This link也可能有帮助