Re: Camel and Kafka manual commit : java.util.ConcurrentModificationException

2022-10-24 Thread Otavio Rodolfo Piske
Hi, >From the code you provided, it's not very clear to me when and where you are calling the commit. Also it's not very clear to me: which version of Camel you are using and which kind of commit factory you are using (async [1] or sync [2]?). That said ...The problem here is that - as explained

Re: How to interrupt camel multicast for subset of enpoints/subroute

2022-10-24 Thread ski n
Hi Jitesh, You can separate the polling of the two FTP into two separate routes: //normal route from("ftp://[username@]hostname[:port]/output";) //code for normal output .to("direct:process_extracted_file"); //error route from("ftp://[username@]hostname[:port]/error";) //code for error output

How to interrupt camel multicast for subset of enpoints/subroute

2022-10-24 Thread Jitesh Adsul
Hello folks !!! I have requirement to poll two ftp folders say "output" and "error" for file. Actual file could come in either of two folders(not both). I tried multicast (even used completionSize of 1) but process keeps waiting as camel waits for both output and error endpoint routes to complete.