我有这条路线:
@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队列中使用,并且必须是事务性的。
我该怎么办?