Tell me about moving messages from one route to another and manual Kafka commit

[Vyacheslav Boyko]

Hi!

It's the first time I use Kafka + Camel chain.
And... what if I have following routes:

// 1 route
from("kafka://my-topic?allowManualCommit=true&autoCommitEnable=false")
    .process(someProcessor)
    .choice()
        .when(simple("${body} == "MY-CONDITION")
            .to("seda://yes-queue")
        .otherwise()
            .to("seda://no-queue")
    .end();

// 2 route
from("seda://yes-route")
    .process(processorYes);

// 3 route
from("seda://no-route")
    .process(processorNo);

Am I right saying that all incoming messages will pass through 1 route
then 2 or 3 route (conditionally) and will park into processorYes or
processorNo. Am I able to perform commit Kafka message not only in 1
route? I mean, am I right that Camel will pass exactly one instance of
Exchange from route 1 to route 2 or 3 and I will be able to perform
Kafka commit in route 2? Or do Camel do something with Kafka fetching
makes me being not able to commit Kafka message in next (after Kafka
consuming) route?


-- 
Vyacheslav Boyko
aka bvn13
mailto:mail4...@gmail.com