So... Am I able to use "direct" instead of "seda", right?
On Mon, 21 Jun 2021 14:49:50 +0000 (UTC)
Andrea Cosentino <ancosen1...@yahoo.com.INVALID> wrote:
> Hello,
>
> The manual commit needs to be done is the same thread of the kafka
> consumer, so you cannot do this in route 2 or route 3.
>
> --
> Andrea Cosentino
> ----------------------------------
> Apache Camel PMC Chair
> Apache Karaf Committer
> Apache Servicemix PMC Member
> Email: ancosen1...@yahoo.com
> Twitter: @oscerd2
> Github: oscerd
>
>
>
>
>
>
> On Monday, June 21, 2021, 02:54:00 PM GMT+2, Vyacheslav Boyko
> <mail4...@gmail.com> wrote:
>
>
>
>
>
> 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?
>
>
