apache camelを使用してデータベースをポーリングする方法

Question

私のデータベースからテーブルを連続的にポーリングし、Kafkaにプッシュしたいと思います。 私はこれにapache camelを使用しています。次のように

私のルートは以下のとおりです。 -

from(timer:every 1 sec). 
to(sql:select first 1000 * from myTable where id > myId). 
to(updateMyId). 
to(kafka:url).end() 

問題は、それが次の繰り返しで更新MYIDを取らないということです。ルートは静的で、最初はmyId = 1の場合、ポーリングは1から続きます。

myIdを動的に更新するにはどうすればよいですか？

Answer 1

更新されるとthis.set myIdプロパティのようにしてください。

from(timer:every 1 sec). 
    to(sql:select first 1000 * from myTable where id >:#${property.myId}). 
    to(updateMyId). 
    to(kafka:url).end(); 

またはBeanにロジックを次のように移動します。

to(sql:select first 1000 * from myTable where id >:#${property.myId}). 
    to(updateMyId).