Apache骆驼集并行消费答案

【问题标题】：Apache camel set parallel consumingApache骆驼集并行消费
【发布时间】：2019-11-11 10:47:20
【问题描述】：

我有这条路线：

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

我该怎么办？

【问题讨论】：

它是作为问题发布的，但实际上适合您作为答案："seda, parallelProcessing() or threads()!?" ...these answers 也可能适用（seda）。

标签： java parallel-processing apache-camel

【解决方案1】：

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

根据您的消息，Split EIP 及其 parallelProcessing() 功能也可以正常工作。

编辑：我发现 Camel in Action 一书的第 13 章可在线免费参考。 This link 也有帮助

【讨论】：