CODEWITHSUNDEEP
javaparallel-processingapache-camel
michele
michele

Reputation: 26598

Apache camel set parallel consuming

I have this route:

@Component
public class MyRoute implements RouteBuilder {

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

}

I want to process more messages from topic in parallel and not sequentially.

The message is consumed from kafka queue and must be transactional.

How can I do?

Upvotes: 0

Views: 841

Answers (1)

ShellDragon
ShellDragon

Reputation: 1722

A common, generic way to handle such a situation is to split your route and use a SEDA Component, with its concurrentConsumers option.

Depending on your message, Split EIP with its parallelProcessing() capability may work as well.

Edit: I found that Chapter 13 of the Camel in Action book is available online for free reference. This link may help as well

Upvotes: 1

Related Questions